easy5 pts · first answer countssparkspark-window-functions

Comparing with the previous day's sales

You want each row of daily store sales to also show the sales of the previous day for the same store. Which expression does this?

w = Window.partitionBy("store").orderBy("day")
df.withColumn("prev_sales", ???)

A.F.first("sales").over(w)B.F.lead("sales", 1).over(w)C.F.lag("sales", 1).over(w)D.F.sum("sales").over(w)

Discussion 0

Join free to post in the discussion.