以秒計算pyspark持續時間

Question

我試圖計算在下面秒的時間差是我的嘗試，

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))) 

給我[datetime.timedelta（0，60），但我想秒鐘差只有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) 

將給，

[60]