天青流分析將多個輸入分組到一個輸出

Question

我正在使用azure流分析，並且希望將同一時間的多個輸入分組到一個輸出。 current output

如何修改我的代碼，它在第一行打印，例如：

{"HO","KSPF","07","03","#300","46091240","2017-05-31T10:17:34:4430000Z"} 

Answer 1

你或許可以碎石Collect在非常小的翻滾窗口，像1毫秒。然後編寫JavaScript UDF以從Collect聚合累積的數組中創建一個事件結果。