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,
Ryan

Reply via email to