Thank you all for your responses.
I've created a custom trigger similar to flink provided EventTimeTrigger,
with few changes. Fire event on onElement(), and do not fire event on
onEventTime() to satisfy my requirement - whenever new event arrives fire
incremental result(result of AggregateFunction
Hi Chandu,
Maybe you can use a custom trigger:
* .trigger(**ContinuousEventTimeTrigger.of(Time.minutes(15)))*
This would continuously trigger your aggregate every period of time.
Thanks,
Rafi
On Thu, Dec 5, 2019 at 1:09 PM Andrey Zagrebin wrote:
> Hi Chandu,
>
> I am not sure whether usi
Hi Chandu,
I am not sure whether using the windowing API is helpful in this case at
all.
At least, you could try to consume the data not only by windowing but also
by a custom stateful function.
You look into the AggregatingState [1]. Then you could do whatever you want
with the current aggregate
*Emit intermediate accumulator(AggregateFunction ACC value) state of a
session window when new event arrives*
AggregateFunction#getResults() is called only when window completes. My
need is emit intermediate accumulator values(result of
AggregateFunction#add()) as well and write them to Sink. Bo
