Можно ли получить непрерывный поток вывода с помощью 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, я погуглил много вещей, прочитал руководство для разработчиков, но заметил, что обрабатывает спорный вывод или что-то подобное. Надеюсь, кто-нибудь может мне помочь!
