Esper：使用分组子句时事件不会传递给订户

Question

我使用Nesper（4.1.2/4.5.0），并且遇到问题：使用分组子句时事件未传递给订户。

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) 
{ ... } 

当我一条一条地删除组，然后一切工作不错。

出了什么问题？

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);