flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Xiang Zhang <xzhan...@ncsu.edu>
Subject ContinuousProcessingTimeTrigger on empty
Date Mon, 11 Jul 2016 16:28:44 GMT
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.

Mime
View raw message