group-by - Esper：使用 group-by 子句时事件不会传递给订阅者

Question

我使用 Nesper (4.1.2/4.5.0) 并且我有一个问题：使用 group-by 子句时事件不会传递给订阅者。

EPL查询：

select Operation, count(*) as OperationCount from OperationEvent.win:time(10 sec) group by Operation

每 5 秒输出一次

订户

public void Update(IDictionary<string, object>[] insertStream, IDictionary<string, object>[] removeStream) 
{ ... }

当我删除 group by 子句时，一切正常。

怎么了？

Answer 1

我解决了我的问题。当我添加地图而不是输入AddEventType方法时，一切正常。我将事件作为地图 (IDictionary<>) 发送，而不是对象。

正确的解决方案：

var map = eventType.GetProperties(BindingFlags.Instance | BindingFlags.Public).ToDictionary(property => property.Name, property => (object) property.PropertyType);

_epService.EPAdministrator.Configuration.AddEventType(eventType.Name, map);