Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- case class Observation(time: Long, value: Double)
- // contains 4 additional columns we need to calculate for each event
- case class WindowStats(sum: Double, min: Double, max: Double, count: Int)
Add Comment
Please, Sign In to add comment
