は、私は以下の秒の時間差を計算しようとしています

Question

をpyspark [datetime.timedelta（0、60）]

from datetime import datetime 
aa = sc.parallelize[('10:40:31', '10:39:31')] 
FMT = "%H:%M:%S" 
duration = aa.map(lambda p: (datetime.strptime(p[0], FMT) - datetime.strptime(p[1], FMT))) 

が私に与え、私の試みであるが、私は秒単位で差をつけたいです60のようにしかありません。私は（.total_secondsにしようとしたことを行うことができますどのように

）が、

Answer 1

は私が.seconds

duration = aa.map(lambda p: (datetime.strptime(p[0], FMT) - datetime.strptime(p[1], FMT))).map(lambda l: l.seconds) 

と1つの以上のマップを追加する必要があり、

を問題を解決し機能していません

[60]