src/services/clock.py
BeforeProposed
+1−1
22
33
44def event_seconds(frame):
5 seconds = F.when(F.col("unit") == "ms", F.col("timestamp"))
5 seconds = F.when(F.col("unit") == "ms", F.floor(F.col("timestamp") / F.lit(1000)))
66 seconds = seconds.otherwise(F.col("timestamp"))
77 return frame.withColumn("eventSecond", seconds.cast("long"))