Hi,
I want to have a trigger fires every 5 seconds in processing time even when
no event comes. I tried
datastream.windowAll(GlobalWindows.create())
.trigger(ContinuousProcessingTimeTrigger.of(Time.seconds(5)))
.apply { MY_APPLY_FUNCTION}
However, ContinuousProcessingTimeTrigger only fires when there is a event. I
want it fires even for a empty 5 seconds time window. Should I user
ContinuousProcessingTimeTrigger?
Xiang
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ContinuousProcessingTimeTrigger-on-empty-tp7914.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
