flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Kostas Kloudas <k.klou...@data-artisans.com>
Subject Re: Flink CEP questions
Date Thu, 17 Aug 2017 13:46:57 GMT
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
	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
		(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: 
for an overview of the CEP library or you can watch the related video.


> On Aug 17, 2017, at 3:32 PM, Basanth Gowda <basanth.gowda@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

View raw message