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 <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 <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 <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 <basanth.go...@gmail.com> 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. > > Want to Alert when CPU usage is above or below certain value > Want to Alert when CPU usage falls in a range > Want to Alert when the above condition matches n times in x interval (could > be seconds, minutes, hours) > 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
