Hi Thanks for the response. But sorry . Am not sure how is it inline with my requirement
Right now, am using SplitterStream to split it based . Which helps me splitting the response to separate streams. The problem is I have a dynamic set of splitstream . the x, y, z is not predefined. It can extend to w, u...So I cannot assign it a specific variable. I only way is to assign it an array. Does it make sense if I use "Array of DataStream" and perform CEP inside a for loop (for every stream) -- View this message in context: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/Categorize-or-GroupBy-datastream-data-and-process-with-CEP-separately-tp15139p15146.html Sent from the Apache Flink Mailing List archive. mailing list archive at Nabble.com.
