首页 > 解决方案 > 滑动窗口生成的事件比原始输入多

问题描述

输入数据: {ticker: 'MSFT', price: 100}

查询:

SELECT * INTO [originalInput] FROM [eventhub-input] /* 341 rows*/
SELECT * INTO [window20Output] FROM window20 /* 676 rows */
SELECT * INTO [window10Output] FROM window10 /* 673 rows */
SELECT * INTO [window5Output] FROM window5 /* 672 rows */
SELECT * INTO [window3Output] FROM window3 /* 674 rows */

窗口是SlidingWindows分组依据 ticker

这里的问题是我的窗口不会生成相同数量的行

我的目标是它们同时生成相同数量的行,这样我就可以将它们全部加入并创建一个输出。

那么这里的问题是什么?

谢谢

标签: azureazure-eventhubazure-stream-analyticsstream-processingcomplex-event-processing

解决方案


推荐阅读