StreamInsight: CleanseInput删除事件

Question

我有个问题我不知道为什么会出现。我有一个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

我非常感谢你的帮助。

向你问好，乔

Answer 1

这些都是由于CTI违规事件而减少的事件。虽然您的AdvanceTimePolicy设置为调整，但这只适用于跨越CTI跨度的间隔事件。也就是说，如果间隔事件在上次发布CTI之前有一个开始时间，而在最后一个发布CTI之后有一个结束时间，则将调整该间隔事件的开始时间(仅)。点事件总是被删除。