我正在使用SiddhiQL进行复杂的事件处理。我的用例是检查在15分钟内是否发生了具有特定过滤器的两个特定类型的事件。比如- If event1[filter 1] and event2[filter 2] within 15 mins
Insert into output stream 在我的例子中,这两个事件中的任何一个都可以首先发生,我需要检查在收到第一个事件后,我是否在15分钟内收到第二个事件。编辑#1 -我已经在下面定义了我的流和事
嗨:我需要在Siddhi流处理中实现以下重复数据消除逻辑。否则,我们应该将事件插入到OutputStream中。
我尝试使用事件模式来进行过滤。但是,我没有发现我可以用Siddhi表达“否定逻辑”,也就是if (not ( e1 --> e2 with same signature in 2 window))。有没有一种聪明的方法来执行这样的事件重复数据删除逻辑?请注意,事件重复数据删除是<e