Hi, Flink’s Pattern API allows you to specify a time interval for a pattern to occur. Use the within call to specify a valid time interval for your pattern.
Pattern<Event, ?> pattern = ...; Pattern<Event, ?> timedPattern = pattern.within(Time.minutes(10)); Cheers, Till On Thu, Jan 5, 2017 at 7:39 AM, madhairsilence <harish.kum...@tcs.com> wrote: > 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. >
