2016-08-21 5 views
-2

나는 rdd에 다음과 같은 기록 시간을 포함하는 구조를 가지고 있습니다 : 02:00:30. 이 형식의 데이터를 두 번째 형식으로 변환하고 싶습니다.이 치료법을하고 싶습니다. 02 * 3600 + 00 * 60 + 30 누군가가 제게이 치료법을 pyspark에서 도와 줄 수 있습니까? 미리 감사드립니다.pyspark로 수학 연산

+2

에 오신 것을 환영 SO합니다. 이 링크를 먼저 확인하십시오. http://stackoverflow.com/help/how-to-ask –

답변

0

지도 그것을

rdd=rdd.map(lambda row: [3600*int(row[0].split(':')[0])+60*int(row[0].split(':')[1])+*int(row[0].split(':')[2]))