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
