Hi, Documentation for

ContinuousEventTimeTrigger

says:

A Trigger that continuously fires based on a given time interval. This fires based on Watermarks.

Does that depend on the stream actually receiving data? I was hoping this Trigger would fire even if not but no luck. What's the difference between

ContinuousEventTimeTrigger

and

EventTimeTrigger

?

Event time processing requires receiving data. I usually add an empty ping message on the data producer to move time forward.

The source where the events comes from are streaming continuously, but the specific node I'm using

ContinuousEventTimeTrigger

receives a message from time to time. I'm sure watermarks are going up because other parts of the processing continues to happen. I was hoping

ContinuousEventTimeTrigger

would solve this for me. As of now can't really understand the difference in behavior between

ContinuousEventTimeTrigger

and

EventTimeTrigger

.

I see.

Appreciate, thank you so much!

Why don’t you open the Java source files?