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