Hi Titus,
have you looked into ProcessFunction? ProcessFunction[1] gives you
access to the two important streaming primitives "time" and "state".
So in your case you can decide flexibly what you want to put into state
and when you want to set and fire a timer (for clean-up) per key.
Regards
Friends, any assistance regarding this?
On Mon, Jul 16, 2018 at 3:44 PM, Titus Rakkesh
wrote:
> Dear All,
>
> We have 2 independent streams which will receive elements in different
> frequency,
>
> DataStream> splittedActivationTuple;
>
> DataStream> unionReloadsStream;
>
> We have a requiremen
Dear All,
We have 2 independent streams which will receive elements in different
frequency,
DataStream> splittedActivationTuple;
DataStream> unionReloadsStream;
We have a requirement to keep "splittedActivationTuple" stream elements in
a Window of eviction time period of 24 hours. So I created
