Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- case class Measurement(nb:Long,x:Double)
- ds.map{m => (m,sum($"x").over(Window.orderBy($"nb"))}
- ds.withColumn("cumsum",sum($"x").over(Window.orderBy($"nb")))
- ds.withColumn("cumsum",sum($"x").over(Window.orderBy($"nb"))).as[(Measurement,Column)]
Add Comment
Please, Sign In to add comment