0

streaminsight で連続出力ストリームを取得することは可能ですか? 私の問題は、ホッピング/タンブリング ウィンドウを使用して入力ストリームに対してクエリを実行すると、入力イベントがない場合にクエリから出力が得られないことです。これは正常に聞こえますが、入力イベントがない場合でも 5 秒ごとに出力を返すウィンドウ メカニズムを取得することは可能ですか?

これは私のコードです。この後、問題が明らかになる可能性があります。

var inputStream = CepStream<ServiceBusMessage>.Create("Inputstream Portal Orders");

// Counts the number of messages in a window of 5 seconds
var countStream = from w in inputStream.TumblingWindow(outputConfig.windowSize)
                  select w.Count();

var queryTemplate = app.CreateQueryTemplate("Count Window Portal Orders", "des...", countStream);

var queryBinder = new QueryBinder(queryTemplate);
queryBinder.BindProducer<ServiceBusMessage>("Inputstream Portal Orders", inputAdapter, config, EventShape.Point);

// Just an simple outputadapter
queryBinder.AddConsumer<long>("output", outputAdapter, outputConfig, EventShape.Point, StreamEventOrder.ChainOrdered);

var query = app.CreateQuery("Counter portal orders", "des...", queryBinder);

query.Start();

私が望む出力は、この入力としましょう：

example input
input time 1: x
input time 2: x
input time 6: x
input time 16: x

expecting output:
2 events in last 5 seconds
1 events in last 5 seconds
0 events in last 5 seconds
1 events in last 5 seconds

このウィンドウ メカニズムが streaminsight 内で可能であることを願っています。開発者ガイドを読んで多くのことを調べましたが、論争の的となる出力などを処理することに注意してください。誰かが私を助けてくれることを願っています!

4

1 に答える 1

0

必要な動作を持つウィンドウ メカニズムはありません。

出力をどのように使用していますか？問題に対処する別の方法があるかもしれません。

于 2013-04-02T13:21:48.930 に答える