Side output in ProcessFunction.onTimer

[Frank Wilson]

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

[Chesnay Schepler]

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