Hello everyone! I need some help trying to implement a CEP Pattern.
This pattern detects if there are no messages from a device for two consecutive days. For this purpose, it checks that after receiving a measurement from a device, no further measurement is received from the same device for 2 days. This is its signature in Esper SQL: insert into CommunicationError > select a1.serialNumber as serialNumber > from pattern [((every a1 = Measure) -> (timer:interval(2 days) and not a2 > = Measure(a2.serialNumber = a1.serialNumber)))] The initial wanted behavior is: receive a1, then wait for 2 days, evaluate if not a2 --> then the pattern is triggered. Is there a way to code this using the CEP library? Or at least, if not with this exact behavior, something similar? I've been testing with a keyed stream by serialNumber and this pattern but it doesn't work as expected val getPattern: Pattern[Measure, Measure] = > Pattern > .begin[Measure]("a1-communication-error") > .within(Time.minutes(3)) //this has been reduced for testing purposes > .notFollowedBy("a2-communication-error") Thank you so much always for your time and insights *Ana Gómez González* <http://twitter.com/angoglez> <https://www.linkedin.com/in/angoglez/>