Re: Couldn't figure out - How to do this in Flink? - Pls assist with suggestions

Thanks Chesnay. I will try that and let you know. Thanks. On Sun, Feb 10, 2019 at 2:31 PM Chesnay Schepler wrote: > You should be able to use a KeyedProcessFunction > for >

Re: Couldn't figure out - How to do this in Flink? - Pls assist with suggestions

You should be able to use a KeyedProcessFunction for that. Find matching elements via keyBy() on the first field. Aggregate into ValueState, send alert if necessary. Upon

Couldn't figure out - How to do this in Flink? - Pls assist with suggestions

Dears, I have a data stream continuously coming, DataStream> splitZTuple; Eg - (775168263,113182,0.0) I have to store this for 24 hrs expiry in somewhere (Window or somewhere) to check against another stream. The second stream is DataStream> splittedVomsTuple which also continuously