If you input data already contains both the SensorID and
FactoryID, why would the following not be sufficient?
DataStream<SensorEvent> sensorEvents = ...;
sensorEvents
.filter(sensorEvent -> sensorEvent.Status.equals("alerte"))
.map(sensorEvent -> sensorEvent.FactoryID)
.addSink(<output>)
If the problem is that you only want one
factory alert to be raised if say, all sensors of a factory go
haywire at once, then you're looking at a time window; e.g.,
to only fire at most one alert every hour:
DataStream<SensorEvent> sensorEvents = ...;
sensorEvents
.filter(sensorEvent -> sensorEvent.Status.equals("alerte"))
.keyBy(sensorEvent -> sensorEvent.FactoryID)
.timeWindow(Time.hours(1))
.apply((WindowFunction<SensorEvent, Alert, String, TimeWindow>) (factoryId, window, input, out)
-> out.collect(new Alert(factoryId)));
.addSink(<output>);
Ultimately it would be good to
understand what exactly you are struggling with, and what you have
tried so far.
On 04/06/2020 15:45, Aissa Elaffani
wrote:
Hello guys,
I have a use case, where I am receiving data from sensors
about their status (Normal or Alerte), {SensorID:"1",
FactoryID:"1", Status:"Normal" ..}, a factory can contain a
lot of sensors, so what I want to do is, if the status of one
sensor in a factory, is Alerte I want to raise an alerte for
all the factory (the factory status must be alerte) ... I did
a
stream.keyBy("FactoryID").window(). can you please suggest
me a window function that can fulfill my use case (if one
sensor of a factory raises "alerte" I want the factory status
to be "alerte") ... I hope someone can understand my use case
!! Sorry for disturbing you, and thak you for your time !
Best,
Aissa
Locked
