1

問題が発生しましたが、それが表示される理由がわかりません。テスト目的でランダムに生成されたイベントを受け取る 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 の間で、すべてのイベントの 5 分の 1 しか通過しない理由を知っている人はいますか? 次の写真を参照してください。それを回避する方法はありますか？

https://dl.dropboxusercontent.com/u/15482726/CleanseIssue.jpg

どんな助けにもとても感謝しています。

よろしく、ジョー

4

1 に答える 1

1

これらは、CTI 違反のためにドロップされたイベントになります。AdvanceTimePolicy を Adjust に設定している間、これは問題の CTI スパンをまたぐ Interval イベントにのみ適用されます。つまり、Interval イベントの開始時刻が最後に発行された CTI より前で、終了時刻が最後に発行された CTI より後の場合、Interval イベントの開始時刻 (のみ) が調整されます。ポイント イベントは常にドロップされます。

于 2014-05-24T13:55:13.113 に答える