Hello
Has anyone work this way? I am asking because I have to get the aggregation
( Sum and Count) for multiple windows size (10 mins, 20 mins, 30 mins)
please let me know if this works properly or is there other good solution.
DataStream data = ...
// append a Long 1 to each record to count it
Hi Antonio,
Cascading window aggregations as done in your example is a good idea and is
preferable if the aggregation function is combinable, which is true for sum
(count can be done as sum of 1s).
Best, Fabian
2018-06-09 4:00 GMT+02:00 antonio saldivar :
> Hello
>
> Has anyone work this way? I
Thank you very much Fabian I found that solution in the link below and this
is the bes fit for my use case
https://stackoverflow.com/questions/47458497/apache-flink-how-to-apply-multiple-counting-window-functions?rq=1
I am still testing how to Count (example. numTransactions >= 3) then I
sum I a
