CEP use case ?

[Aissa Elaffani <ai...@gmail.com>]

Hello Guys,
I have some sensors  generating some data about their (température,
humidity, positioning , ...) and I want to apply some rules (simple
conditions, if température>25, ...), in order to define if the sensor is on
"Normal" status or "Alerte" status. Do i need to use flink CEP, or just the
DataStream Api is suffisant to define the status of each sensor.
Sorry for disturbing you ! I hope someone can help me with that.
Thank you guys.
Best
Aissa

Re: CEP use case ?

[David Anderson <da...@alpinegizmo.com>]

If the rules can be implemented by examining events in isolation (e.g.,
temperature > 25), then the DataStream API is all you need. But if you want
rules that are looking for temporal patterns that play across multiple
events, then CEP or MATCH_RECOGNIZE (part of Flink SQL) will simplify
the implementation. An example of a more complex rule would be something
like "the temperature rose by more than 5 degrees during an hour".

Note that both CEP and MATCH_RECOGZNIZE are designed for situations in
which the rules are known at compile time.

Best,
David

On Fri, Jul 17, 2020 at 2:05 AM Aissa Elaffani <ai...@gmail.com>
wrote:

> Hello Guys,
> I have some sensors  generating some data about their (température,
> humidity, positioning , ...) and I want to apply some rules (simple
> conditions, if température>25, ...), in order to define if the sensor is on
> "Normal" status or "Alerte" status. Do i need to use flink CEP, or just the
> DataStream Api is suffisant to define the status of each sensor.
> Sorry for disturbing you ! I hope someone can help me with that.
> Thank you guys.
> Best
> Aissa
>