我遇到了一个问题,我不知道它为什么会出现。我有一个 InputAdapter 接收随机生成的事件用于测试目的。
以下代码创建了一个删除大量事件的查询。我实际上想保留它。
var atgs = new AdvanceTimeGenerationSettings(config.Input.EventCount,
TimeSpan.FromSeconds(config.Input.Delay), true);
var ats = new AdvanceTimeSettings(atgs, null, AdvanceTimePolicy.Adjust);
var dstream = CepStream<Dataclass>.Create("Data Input Stream", typeof (InAdapterFactory),
config.Input, EventShape.Point, ats);
Query output = dstream.ToQuery(myApplication,
"Sample unbounded query",
"Query with no output adapter",
EventShape.Point,
StreamEventOrder.FullyOrdered);
output.Start();
var instream = output.ToStream<Dataclass>();
有谁知道为什么在 DataInputStream 和 DatainputStream_CleanseInput 之间只有五分之一的事件通过?见下图。有没有办法避免这种情况?
https://dl.dropboxusercontent.com/u/15482726/CleanseIssue.jpg
我非常感谢任何帮助。
最好的问候,乔