Re: Flink CEP

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

Re: Flink CEP

Daniel Skates
Hi Flink team,

Any ideas on how to achieve the below outcome:

I have a stream of Strings, with the words Start, Step and Stop.  I'm trying to build a pattern for a Start followed by another Start, without a Stop in between.

e.g. this would give an alert due to lines 5 and 8:
Start
Step
Step
Stop
Start
Step
Step
Start
Step
Stop
Step

Daniel


On Wed, Mar 22, 2017 at 6:33 PM, Daniel Skates <[hidden email]> wrote:
Hello,

I'm having difficulty with the Flink CEP constructs.  Essentially I have a stream of Strings, with the words Start, Step and Stop.  I'm trying to build a pattern for a Start followed by another Start, without a Stop in between.

e.g. this would give an alert due to lines 5 and 8:
Start
Step
Step
Stop
Start
Step
Step
Start
Step
Stop
Step

Any direction would be greatly appreciated,

Cheers,

Daniel

Reply | Threaded
Open this post in threaded view
|

Re: Flink CEP

Kostas Kloudas
Hi Daniel,

The NOT operation is not yet supported in the CEP library but there is an open 
issue https://issues.apache.org/jira/browse/FLINK-3320 and we are working on 
integrating it in the next release of the CEP library.

Please monitor the issue to check the progress on the topic.

Now what you could do until this is done, is that you can specify a pattern that also
accepts the Stop, and then take the matched patterns stream and filter out the ones 
that include it. 

Could this help you achieve what you want?

Kostas

On Mar 26, 2017, at 5:01 PM, Daniel Skates <[hidden email]> wrote:

Hi Flink team,

Any ideas on how to achieve the below outcome:

I have a stream of Strings, with the words Start, Step and Stop.  I'm trying to build a pattern for a Start followed by another Start, without a Stop in between.

e.g. this would give an alert due to lines 5 and 8:
Start
Step
Step
Stop
Start
Step
Step
Start
Step
Stop
Step

Daniel


On Wed, Mar 22, 2017 at 6:33 PM, Daniel Skates <[hidden email]> wrote:
Hello,

I'm having difficulty with the Flink CEP constructs.  Essentially I have a stream of Strings, with the words Start, Step and Stop.  I'm trying to build a pattern for a Start followed by another Start, without a Stop in between.

e.g. this would give an alert due to lines 5 and 8:
Start
Step
Step
Stop
Start
Step
Step
Start
Step
Stop
Step

Any direction would be greatly appreciated,

Cheers,

Daniel