0

我需要实现一个长度为 (5) 的动态滑动窗口，其中我有来自不同航班的传入航班状态进入一个流。

基于来自不同航班的 flight_id 属性 - 必须在运行时创建长度为 5 的动态窗口，并且必须单独维护其平均速度。

当我将具有不同航班 ID 和速度的多个航班插入其中时，Drools Fusion 中的这个示例不起作用 - http://books.google.co.in/books?id=trrfxX8JCisC&pg=PA136&lpg=PA136&dq=flight+average+speed+示例+drools+fusion&source=bl&ots=NpRv7D32Us&sig=6XbWtIQ2T1idGMQRU_hQZgmd8fc&hl=en&sa=X&ei=RBAUU92yIsLkiAenFg&ved=0CDIQ6AEwAQ#v=onepage&q=flight%20average%20speed%20example%20drools%20fusion&f=false

当检测到新的航班 ID 时，窗口会重置。

请让我知道 Drools Fusion 或 Esper 或任何其他开源 CEP 中是否有解决方案。

提前致谢。

4

1 回答 1

0

该链接不起作用。

您能否澄清“动态窗口”和“窗口重置”？目前尚不清楚这可能意味着什么。

在 Esper 中，我在 "4.2.6.1. Distinct Events for the Initiating Condition" 的文档中找到了一个示例，并为您重写了可能符合有些模糊要求的内容：

create context Flight initiated by distinct(flightId) FlightEVent 
  terminated after 5 seconds; // you don't mention when to throw a flight away
context Flight select avg(speed) from FlightEvent.win:length(5);
于 2014-03-03T12:20:01.293 回答