Find centralized, trusted content and collaborate around the technologies you use most.
Teams
Q&A for work
Connect and share knowledge within a single location that is structured and easy to search.
我是Siddhi语言新手。我只需要在事件流的前 10 分钟内获取事件。有没有办法完成这个任务?这是定义的输入流。
Siddhi
define stream InputDataStream (timestamp long, obd2_MAF float, obd2_engine_rpm float);
目前无法在 CEP 的第一个 10 分钟内获得事件
siddhi 时间窗口将滑动并保留最后 10 分钟的事件。
您拥有的一个选项是创建一个 siddhi 查询并忽略时间戳值大于 10 分钟 + 第一个事件的时间戳的事件,这可以使用过滤器查询来实现。
请参考[1]
[1] https://docs.wso2.com/display/CEP210/Filters