Comments 2
1) есть ли аналог ktable kafka stream и можно ли делать join в новый ktable на основе двух других ktable?
2) может ли при оконной агрегации записывать только финальных результат окна ? а не как сейчас в кафке , если заселектить результирующий топик окна, то там будут все изменения, а не только финальные "таймаута" окна.
3) существует ли такой тип закрытия: по таймауту допустим если нету сообщений 1 минуту или если обработали допустим 1000 сообщений ?
1) Нет, аналога ktable нету. Однако можно использовть MapState для работы с сопоставлениями.
2) Конечно. Можно считать постепенно (как кафка), а можно буферизировать данные пока окно не будет признаным готовым к обработке("таймаута" окна).
3) Существуют, для этого используются ProcessingTimeTrigger, CountTrigger соответсвенно.
Apache Flink и потоковая обработка данных для решения задач IoT