在前 10 分钟内获取事件



我是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

最新更新