flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ryan Conway <ryanmackenziecon...@gmail.com>
Subject Window Functions and Empty Panes
Date Mon, 17 Apr 2017 23:49:53 GMT
Hello Flinkers,

Is there a means of configuring a windowed stream such that its window
function is invoked for empty panes?

Looking at the source of WindowOperator in Flink 1.2.0 (line 473), I see
that the user's window function is invoked only when the pane isn't empty.
I am hoping for a means of overriding this behavior.

Alternatively... is there another mean of creating a stream with a periodic
output based on each period's inputs and some stored state?

Thank you,

View raw message