Thank you very much.
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
Hi Dawid
I use Flink to calculate IOT device alarms,My scenario is that each device
has an independent alarm strategy,For example, I calculate that the
temperature of 10 consecutive event data of a device is higher than 10
degrees。
I use:
sourceStream.keyBy("deviceNo")
.flatMap(new
Hi,
How to calculate one alarm strategy for each device or one alarm strategy
for each type of IOT device。
My way is:
1. Use ListStateto store device state data for calculation
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/