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


Reply via email to