flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From M Singh <mans2si...@yahoo.com>
Subject Re: Flink : CEP processing
Date Tue, 09 Aug 2016 17:40:44 GMT
Thanks Sameer.
So does that mean that if the events keys are not same we cannot use the CEP pattern match
?  What if events are coming from different sources and need to be correlated ?

    On Tuesday, August 9, 2016 9:40 AM, Sameer W <sameer@axiomine.com> wrote:

You will need to use keyBy operation first to get all the events you need monitored in a pattern
on the same node. Only then can you apply Pattern because it depends on the order of the events
(first, next, followed by). I even had to make sure that the events were correctly sorted
by timestamps to ensure that the first,next and followed by works correctly.
On Tue, Aug 9, 2016 at 12:17 PM, M Singh <mans2singh@yahoo.com> wrote:

Hey Folks:
I have a question about CEP processing in Flink - How does flink processing work when we have
multiple partitions in which the events used in the pattern sequence might be scattered across
multiple partitions on multiple nodes ?
Thanks for your insight.

View raw message