flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Kostas Kloudas <k.klou...@data-artisans.com>
Subject Re: ContinuousProcessingTimeTrigger on empty
Date Mon, 11 Jul 2016 17:43:07 GMT
Hi Xiang,

Currently this is not supported by the trigger provided by Flink, as
a window with no data, is a non-existing window for Flink.

What you could do is emit periodically dummy elements from your source (so 
that all windows have at least one element) and make sure that your windowing 
function ignores them when computing the final result. But I am not sure 
how you can do it in processing time. 

Kostas 

> On Jul 11, 2016, at 6:28 PM, Xiang Zhang <xzhang23@ncsu.edu> wrote:
> 
> 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