continious輸出的StreamInsight

是否有可能得到一個連續輸出流用的StreamInsight？我的問題是，當我做出一個跳躍/翻滾窗口InputStream的查詢，查詢犯規給我任何的輸出，當沒有輸入事件。這聽起來很正常，但是有沒有可能獲得一個窗口機制，在沒有輸入事件的情況下每5秒鐘輸出一次？continious輸出的StreamInsight

這是我的代碼也許問題在此之後變得清晰：

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內是可能的，我搜索了很多東西閱讀開發者指南，但注意到處理有爭議的輸出或類似的東西。希望有人能幫助我！

來源

2013-04-01 Carlo

。它有你想要的行爲沒有窗口機制。

你如何使用輸出？可能有另一種方法來解決這個問題。

來源

2013-04-02 13:21:48 TXPower275

我在streaminsight的學習階段，所以我的輸出只是爲了在我的控制檯中進行調試，但是在將來，我會在它上面耦合另一個需要輸出的系統來計算關於當前值的預測。我正在考慮將數據寫入csv文件，以便其他系統可以讀取該文件中的最後一個值。但是當由於窗口機制而沒有事件時，文件不是最新的。耦合系統可以通過數據挖掘系統，如神經網絡或支持向量機。 – Carlo

我想插入虛擬活動，從而使窗口計數所有的時間和過濾掉後，我有我的計數窗口的假事件。感謝您的幫助 – Carlo

你的事件開始和結束時間，其確定事件是否有效。可以肯定地說，如果在你看的時候沒有有效的事件，那麼計數顯然爲零。 – TXPower275

continious輸出的StreamInsight

回答

相關問題