Re: Flink WindowedStream - Need assistance

2018-07-17 Thread Titus Rakkesh
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> uni

Flink WindowedStream - Need assistance

2018-07-16 Thread Titus Rakkesh
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