flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jayant Ameta <wittyam...@gmail.com>
Subject Re: How to apply patterns from a source onto another datastream?
Date Mon, 25 Dec 2017 04:53:18 GMT
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.dawid@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 <wittyameta@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.dawid@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 <wittyameta@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
> >
> >
>
>

Mime
View raw message