2012-03-13 5 views
0

Nesper(4.1.2/4.5.0)を使用していて、グループバイ句を使用しているときにサブスクライバにイベントが渡されません。Esper:グループバイ句を使用しているときにイベントがサブスクライバに渡されない

EPLクエリ:最後の5秒毎

加入者

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

私はgroup by句を削除すると、その後、すべてが素敵な作品

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

出力。

どうしたのですか?

答えて

0

私は私の問題を解決しました。 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);

関連する問題