Как я могу получить скользящую сумму потоковых событий?

У меня есть источник, который генерирует целочисленные события.

Для каждого нового целого числа я хотел бы суммировать его со всеми целыми числами, которые были переданы за предыдущий час, и передать это значение на следующий шаг.

Каков идиоматический способ вычисления, а затем вывода суммы целого числа текущего события в сочетании с целыми числами всех событий за предыдущий час? Я могу думать о двух вариантах, но чувствую, что что-то упускаю:

  • Используйте скользящее окно размером в один час, которое сдвигается на одну миллисекунду. Это гарантирует, что всегда есть окно, которое простирается от последнего события ровно на один час назад.
  • Создайте свою собственную функцию процесса, которая отслеживает предыдущие целые числа, которые меньше или равны одному часу. Используйте это состояние для выполнения моих расчетов.
Формы c голосовым вводом в React с помощью Speechly
Формы c голосовым вводом в React с помощью Speechly
Пытались ли вы когда-нибудь заполнить веб-форму в области электронной коммерции, которая требует много кликов и выбора? Вас попросят заполнить дату,...
Стилизация и валидация html-формы без использования JavaScript (только HTML/CSS)
Стилизация и валидация html-формы без использования JavaScript (только HTML/CSS)
Будучи разработчиком веб-приложений, легко впасть в заблуждение, считая, что приложение без JavaScript не имеет права на жизнь. Нам становится удобно...
Flatpickr: простой модуль календаря для вашего приложения на React
Flatpickr: простой модуль календаря для вашего приложения на React
Если вы ищете пакет для быстрой интеграции календаря с выбором даты в ваше приложения, то библиотека Flatpickr отлично справится с этой задачей....
В чем разница между Promise и Observable?
В чем разница между Promise и Observable?
Разберитесь в этом вопросе, и вы значительно повысите уровень своей компетенции.
Что такое cURL в PHP? Встроенные функции и пример GET запроса
Что такое cURL в PHP? Встроенные функции и пример GET запроса
Клиент для URL-адресов, cURL, позволяет взаимодействовать с множеством различных серверов по множеству различных протоколов с синтаксисом URL.
Четыре эффективных способа центрирования блочных элементов в CSS
Четыре эффективных способа центрирования блочных элементов в CSS
У каждого из нас бывали случаи, когда нам нужно отцентрировать блочный элемент, но мы не знаем, как это сделать. Даже если мы реализуем какой-то...
1
0
24
1
Перейти к ответу Данный вопрос помечен как решенный

Ответы 1

Ответ принят как подходящий

Вы можете сделать это с помощью Flink SQL, используя дополнительное окно. Что-то вроде этого:

SELECT
    SUM(*) OVER last_hour AS rolling_sum
FROM Events
WINDOW last_hour AS (
    ORDER BY eventTime
    RANGE BETWEEN INTERVAL '1' HOUR PRECEDING AND CURRENT ROW
)

См. НАД Агрегация из документов Flink SQL для получения дополнительной информации. Вы также можете использовать Table API, см. Через Windows.

Другие вопросы по теме