flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Konstantin Knauf <konstantin.kn...@tngtech.com>
Subject Re: Window Functions and Empty Panes
Date Tue, 18 Apr 2017 04:53:03 GMT
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.knauf@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


Mime
View raw message