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 StateAlarmCalculationFunction()).....
StateAlarmCalculationFunction extends RichFlatMapFunction
StateAlarmCalculationFunction use ListState<DeviceState> deviceListState to
store the device state. After each device data comes in, I load the
deviceListState for calculation,But I don't think it's smart enough. Is
there anything better
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
