Cc: user@flink.apache.org
Subject: Re: A way to purge an empty session
Hi Gwenhael,
have you considered to use a ProcessFunction? With a ProcessFunction you have
direct access to state (that you register yourself) and you can register timers
that trigger a callback function when they expire.
So
Hi Gwenhael,
have you considered to use a ProcessFunction? With a ProcessFunction you
have direct access to state (that you register yourself) and you can
register timers that trigger a callback function when they expire.
So you can cleanup state when you receive an element or when a timer
expires
