我正在尝试构建一个执行计划，将不同的事件聚合为一个并计算事件（CurrentEventId） . 该计划如下所示：
define stream inStream (correlation_EventName string, LastEventId int, CurrentEventId int);
partition with (CurrentEventId of inStream)
begin
from inStream#window.timeBatch(10 sec)
select correlation_EventName as meta_Label, CurrentEventId as meta_Id, LastEventId as correlation_From, CurrentEventId as correlation_To, count(CurrentEventId) as correlation_Value
insert into outStream
end;
实际上，我有以下输出：
Event: {"event":{"metaData":{"Label":"StartCalculationEvent","Id":2},"correlationData":{"From":2,"To":2,"Value":66}}}
Event: {"event":{"metaData":{"Label":"LoginEvent","Id":1},"correlationData":{"From":1,"To":1,"Value":693}}}
我每10秒钟只需要 single 事件，而不是多个事件 . 此事件应具有以下格式：
[
{
"event":{"metaData":"..."}
},
{
"event":{"metaData":"..."}
}
]
你对如何实现这个有一个想法吗？
1 回答
使用siddhi分区，将为每个分区变量生成单独的事件（在本例中为
CurrentEventId） . 由于您有两个CurrentEventIds，因此您会在outStream中收到两个事件 . 如果有三个CurrentEventIds，您将分别收到3个事件 .截至目前，无法按照您的要求在siddhi中批量处理事件 . 有一个相关的Jira，它与您期望的功能类似 .