flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aljoscha Krettek <aljos...@apache.org>
Subject Re: CEP and Within Clause
Date Mon, 01 Aug 2016 21:12:50 GMT
+Till, looping him in directly, he probably missed this because he was away
for a while.

On Tue, 26 Jul 2016 at 18:21 Sameer W <sameer@axiomine.com> wrote:

> Hi,
> It looks like the WithIn clause of CEP uses Tumbling Windows. I could get
> it to use Sliding windows by using an upstream pipeline which uses Sliding
> Windows and produces repeating elements (in each sliding window) and
> applying a Watermark assigner on the resulting stream with elements
> duplicated. I wanted to use the "followedBy" pattern where there is a
> strong need for sliding windows.
> Is there a plan to add sliding windows to the within clause at some point?
> The PatternStream class's "select" and "flatSelect" have overloaded
> versions which take PatternTimeOut variable. Is there a way to insert some
> of those elements back to the front of the stream. Say I am trying to find
> a pattern where two temperature readings >150 within 6 second window should
> raise an alert. If only one was found, can I insert that one back in the
> front of the stream on that task node (for that window pane) so that I can
> find a pattern match in the events occurring in the next 6 seconds. If I
> can do that, I don't need sliding windows. Else I cannot avoid using them
> for such scenarios.
> Thanks,
> Sameer

View raw message