Sorry for the late response due to time difference between Berlin and Seoul :-)
What you are asking is why I'm trying to modify the condition of the original
ternary operator used in EventTimeTrigger.onEventTime?
If that is your question, I've already answered it on the first in the thread
as
Out of curiosity, why don't you want to keep it like this?
@Override
public TriggerResult onEventTime(long time, TimeWindow window,
TriggerContext ctx) {
return time == window.maxTimestamp() ?
TriggerResult.FIRE :
Hi Aljoscha,
If that is the only case, I need to return TriggerResult.CONTINUE when time >
window.maxTimestamp.
It is very fortunate that onEventTime is not called when time <
window.maxTimestamp except my timer.
Thanks a lot for your quick reply.
Best,
- Dongwon
2018. 7. 23. 오후 10:58,
Hi,
If you set an allowed lateness that is greater than zero you will get another
call to onEventTime() on window.maxTimestamp + allowedLateness.
Does that help answer your question?
Best,
Aljoscha
> On 23. Jul 2018, at 15:40, Dongwon Kim wrote:
>
> Hi all,
>
> I want to be sure about when
Hi all,
I want to be sure about when EventTimeTrigger.onEventTime() method is
called with event-time session windows.
It returns TriggerResult.FIRE only when the timestamp of the registered
timer equals to the max timestamp of the current window:
@Override
public TriggerResult onEventTime(long
