Hi, Muazim
Flink is an incremental computing framework, in streaming mode it considers
data to be unbounded, so every piece of data that comes in triggers the
computation logic because it doesn't know when the data will end.
Based on your description, I understand that you may have a full data
com
Hi Team,
I am new to Flink. I have this use case where I have a dataStream of
Doubles and I am trying to get the total sum of whole DataStream.
I have used ReduceFunction and AggregateFunction.
Case 1: In Reduced function the output is dataStream of rolling Sum. To get
the final Sum I have to tra
