flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Chesnay Schepler <ches...@apache.org>
Subject Re: Side output in ProcessFunction.onTimer
Date Wed, 19 Jun 2019 08:47:38 GMT
ProcessFunction#onTimer provides an OnTimerContext parameter which 
allows you to use side-outputs.

On 18/06/2019 17:41, Frank Wilson wrote:
> Hi,
>
> Is there a way to make side outputs in an onTimer callback in 
> ProcessFunction?
>
> I want to side output events that belong to a session that was below 
> the minimum duration threshold. Currently these events are just 
> discarded but I’d like more traceability.
>
> Thanks,
>
> Frank



Mime
View raw message