etOrElse('-')+','+endTime.getOrElse('-')
}
Also here:
https://gist.github.com/dbciar/904e2d35d6aae30214666de1176f1d7c
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Window-Functions-with-Incremental-Aggregation-tp82
Hello everyone,
I'm trying to understand how I can use the Incremental Aggregation + Window
Functions, as I've been unsuccessfully trying for a while now.
The use-case is one where I have a stream of objects, I want to count the
number of objects within a sliding window, and then within the w
