indows.of(Time.minutes(1)))
> .trigger(PurgingTrigger.of(CountTrigger.of(5)))
>
> Thinking that if I send 2 elements of data, it would collect them after a
> minute.
> But that doesn't seem to be happening.
>
> Is my understanding of how windows and triggers work correct?
>
>
I wrote this simple test:
.window(TumblingProcessingTimeWindows.of(Time.minutes(1)))
.trigger(PurgingTrigger.of(CountTrigger.of(5)))
Thinking that if I send 2 elements of data, it would collect them after a
minute.
But that doesn't seem to be happening.
Is my understanding of how window
is replaced.
In your example, the time trigger is replaced by the count trigger, i.e., the
window is only evaluated after the 100th element was received.
This blog post discusses windows and triggers [1].
Best, Fabian
[1] http://flink.apache.org/news/2015/12/04/Introducing-windows.html
2016-04-20
ult trigger of the window is
>> replaced.
>> In your example, the time trigger is replaced by the count trigger, i.e.,
>> the window is only evaluated after the 100th element was received.
>>
>> This blog post discusses windows and triggers [1].
>>
>> Best, Fabian
s
> replaced.
> In your example, the time trigger is replaced by the count trigger, i.e.,
> the window is only evaluated after the 100th element was received.
>
> This blog post discusses windows and triggers [1].
>
> Best, Fabian
>
> [1] http://flink.apache.org/news/201
triggers [1].
Best, Fabian
[1] http://flink.apache.org/news/2015/12/04/Introducing-windows.html
2016-04-20 13:20 GMT+02:00 Piyush Shrivastava :
I wanted to know how Windows and Triggers work in Flink. I am creating a time
window of 20 seconds and a count trigger of 100.
stream.keyBy(0
Hi Piyush,
if you explicitly set a trigger, the default trigger of the window is
replaced.
In your example, the time trigger is replaced by the count trigger, i.e.,
the window is only evaluated after the 100th element was received.
This blog post discusses windows and triggers [1].
Best, Fabian
I wanted to know how Windows and Triggers work in Flink. I am creating a time
window of 20 seconds and a count trigger of 100.
stream.keyBy(0)
.timeWindow(Time.seconds(20))
.trigger(CountTrigger.of(100))
In this case, when will my window get triggered? When 20 seconds
