CEP use case ?

[Aissa Elaffani]

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 

[David Anderson-3]

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 <[hidden email]> 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