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
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
Hi Aissa,
Flink CEP is an api that processes multi-event matching with a pattern,
like (START MIDDLE+ END).
If you can calculate the "sensor_status" by one record, I think Flink
DataStream API / Table & SQL API
could satisfy your requirement already.
Aissa Elaffani 于2020年6月25日周四 下午11:35写道:
>
Hello Guys,
I am asking if the CEP Api can resolve my use case. Actually, I have a lot
of sensors generating some data, and I want to apply a rules engine on
those sensor's data,in order to define a "sensor_status" if it is Normal or
Alert or warning.for each record I want to apply some conditions