Создайте SessionWindow из списка. Агрегированные входные данные. Ключ groupBy, сохраните агрегированное значение в KTable.
Для каждого ключа возьмите список данных, затем используйте модель ML для прогнозирования выходных данных.
СоздатьNEW SessionWindow, потому что мы хотим получить доступ к предыдущему прогнозу в логике слияния.
Каким-то образом SessionWindow внутри SessionWindow НЕ работает. Вопрос в том, как получить доступ к предыдущему состоянию окна без использования интерактивных запросов.