Hey,
I have a question regarding CEP, assume I have a stream of readings from
various sensors. The application is running in EventTime, so according to
the CEP docs the events are buffered and sorted by timestamp ascending.
So, I want to record the situations when reading from the sensor goes above
some threshold. But what I am interested in is to have a whole match for
the period when the event was above the threshold.
I tried to implement a single pattern that was more or less something:
Pattern.begin[Reading]("beginning")
.where(_.data() < Threshold)
.oneOrMore
.greedy
.consecutive
But now it produces multiple partial matches that I can't eliminate. For
example for threshold = 350, I have a stream:
300, 400, 500, 300
And then I get the following lists of events [400], [400, 500], [500].
Is there a way to eliminate those partial matches ??
Best Regards,
Dom.
