连续输出流洞察

Question

是否可以通过 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 中是可能的，我在 Google 上搜索了很多东西，阅读了开发人员指南，但注意到处理有争议的输出或类似的东西。 希望有人可以帮助我！

Answer 1

没有具有您想要的行为的窗口机制。

您如何使用输出？可能有另一种方法来解决这个问题。