flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From David Koch <ogd...@googlemail.com>
Subject Listening to timed-out patterns in Flink CEP
Date Thu, 06 Oct 2016 13:08:19 GMT

With Flink CEP, is there a way to actively listen to pattern matches that
time out? I am under the impression that this is not possible.

In my case I partition a stream containing user web navigation by "userId"
to look for sequences of Event A, followed by B within 4 seconds for each

I registered a PatternTimeoutFunction which assuming a non-match only fires
upon the first event after the specified timeout. For example, given user
X: Event A, 20 seconds later Event B (or any other type of event).

I'd rather have a notification fire directly upon the 4 second interval
expiring since passive invalidation is not really applicable in my case.

How, if at all can this be achieved with Flink CEP?



View raw message