Thanks for you reply and absolutely apologies for my insanity Thats the place I confuse a lot.
The keyedstream, processe by unique key. But as per the example is see, I can make a pattern like temperature > 90...temperature > 80... within 'T' minutes. What am trying to achieve ,is "Temperate is > 90 continously for the past ten minutes" just like the "within(X minutes)", does CEP has "for(X minutes)" syntax? Thats the reason, I thought of using "SpitStream" and create a "Window" for a given time and the apply CEP for that stream. But I stuck with dynamic "Key" issue. -- 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-tp15139p15153.html Sent from the Apache Flink Mailing List archive. mailing list archive at Nabble.com.
