用pyspark進行數學運算

Question

我在rdd中有一個包含這樣的記錄時間的結構：02:00:30。 我想從這種格式的數據轉換爲第二種格式，我想要做這個處理：02 * 3600 + 00 * 60 + 30 有人可以請幫我在pyspark做這種治療嗎？先謝謝你。

Answer 1

地圖它

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