Hi Ryan, afaik there is no way to override this behaviour.
Did you have a look at the ProcessFunction [1]? Depending on your specific requirements you might be able to re-implement the desired functionality on top of it, but you will have to do all the time-handling yourself and you do not have window-scoped state. Cheers, Konstantin [1] https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/stream/process_function.html On 18.04.2017 01:49, Ryan Conway wrote: > 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 -- Konstantin Knauf * konstantin.kn...@tngtech.com * +49-174-3413182 TNG Technology Consulting GmbH, Betastr. 13a, 85774 Unterföhring Geschäftsführer: Henrik Klagges, Christoph Stock, Dr. Robert Dahlke Sitz: Unterföhring * Amtsgericht München * HRB 135082
signature.asc
Description: OpenPGP digital signature
