我是Siddhi
语言的新手。我只需要在事件流的前 10 分钟内获取事件。有没有办法完成这项任务?下面是定义的输入流。
define stream InputDataStream (timestamp long, obd2_MAF float, obd2_engine_rpm float);
目前
无法在 CEP 中获取第 10 个 10 分钟内
的事件悉达时间窗口将滑动并将过去 10 分钟的事件保留在其中。
您有一个选择是创建一个 Siddhi 查询并忽略时间戳值大于 10 分钟 + 第一个事件的时间戳的事件,这可以使用过滤器查询来实现。
请参考 [1]
[1] https://docs.wso2.com/display/CEP210/Filters