Re: Flink CEP questions

Posted by Kostas Kloudas on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Flink-CEP-questions-tp14971p14972.html

Hi Basanth,

This is the documentation page can be found here: https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/libs/cep.html

For:

3) you should use the times(N) and the within(TIME) clauses

  4) if by continuously you mean without stopping, then you should use the followedBy() or next() 

(check "Combining Patterns” https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/libs/cep.html#combining-patterns in the docs above)

I am not aware of any examples but you can check this slides: 

https://www.slideshare.net/dataArtisans/kostas-kloudas-complex-event-processing-with-flink-the-state-of-flinkcep

for an overview of the CEP library or you can watch the related video.

Cheers,

Kostas

On Aug 17, 2017, at 3:32 PM, Basanth Gowda <[hidden email]> wrote:

All,

New to Flink and more so with Flink CEP.

I want to write a sample program that does the following :

Lets suppose data cpu usage of a given server.

1. Want to Alert when CPU usage is above or below certain value
2. Want to Alert when CPU usage falls in a range
3. Want to Alert when the above condition matches n times in x interval (could be seconds, minutes, hours)
4. Want to Alert when the above condition happens continuously for x interval (could be seconds, minutes or hours) 

How would we achieve 3, 4 in the list above ? Any examples that I refer to ?

thank you,

Basanth