Как достичь такого же эффекта раздвижного окна Spark Streaming, которое проходит с интервалом X скольжения по последней длине окна Y.Скользящее окно над интервалом на Esper
Глядя на Эспера, должно быть win:time и win:time_batch, где выигрыш: время> = победа: время_батча.
В esper эквивалент должен объявлять контекст. Создать контекст BucketOf10Sec start @now end через 10 минут; Контекст BucketOf10Sec выбирает сумму (цену) из MyEvent;
мне удалось решить эту проблему менее настраиваемый, но простой способ (по крайней мере для меня), с помощью win:time с OUTPUT EVERY x
SELECT value
FROM Entry.win:time(10 sec)
OUTPUT EVERY 5 sec
Работы, как я предполагал - каждые 5 секунд, я получаю результаты из последних 10 секунд.