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