Hi Dawid, Since dynamic patterns are not available in Flink CEP, I am thinking about skipping the CEP altogether, and mimic the functionality using windows stream. I am mostly interested in *times* and *within* methods. Basically, rewriting my own logic on windowed stream to match the pattern, and count the number of matching events within a time window. Do you know if there is any similar example in the docs?
Jayant Ameta On Fri, Dec 22, 2017 at 1:24 PM, Dawid Wysakowicz < wysakowicz.da...@gmail.com> wrote: > Hi Jayant, > > Could you elaborate a bit more what you mean? Flink’s windows are not used > in Flink CEP. They are a different concept. > > > On 20 Dec 2017, at 09:23, Jayant Ameta <wittyam...@gmail.com> wrote: > > > > Would it be possible to get the same result using windows? > > > > Jayant Ameta > > > > On Tue, Dec 19, 2017 at 3:23 PM, Dawid Wysakowicz < > wysakowicz.da...@gmail.com> wrote: > > It is not possible at this moment. FlinkCEP can handle only one Pattern > applied statically. There is a JIRA ticket for that: > https://issues.apache.org/jira/browse/FLINK-7129 . > > > > > On 19 Dec 2017, at 10:10, Jayant Ameta <wittyam...@gmail.com> wrote: > > > > > > I've a datastream of events, and another datastream of patterns. The > patterns are provided by users at runtime, and they need to come via a > Kafka topic. I need to apply each of the pattern on the event stream using > Flink-CEP. Is there a way to get a PatternStream from the DataStream when I > don't know the pattern beforehand? > > > > > > https://stackoverflow.com/questions/47883408/apache- > flink-how-to-apply-patterns-from-a-source-onto-another-datastream > > > > > >
