Входные данные: {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
Проблема в том, что мои окна не генерируют одинаковое количество строк
Моя цель - чтобы они генерировали одинаковое количество строк вв то же время, чтобы я мог присоединиться к ним и создать один выход.
Так в чем же проблема?
Спасибо