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.