Всем привет!

Выкладываем запись 5 встречи сезона “In the flow” с обсуждением 5-6 глав. В этот раз мы увидели, как идеи из обсуждений статей в прошлых выпусках реализуются в API Flink.

В рамках выпуска:
🔶 Обсудили сходства и различия в подходе при работе API Flink и другими функциональными API (такими как Java Stream)
🔶 Посмотрели, о каких особенностях реализации стоит помнить при использовании API Flink
🔶 Порассуждали о сериализации, TypeInformation и о том, какие проблемы могут возникать
🔶 Прошлись по примерам кода, работающим с временными метками и окнами
🔶 Провели параллели с выпуском по “The Dataflow Model” и посмотрели на примеры таких компонентов, как Assigner и Trigger

Как обычно, ставьте 🔥, если выпуск был интересен! А завтра в 21:00 по мск ждите анонса со ссылкой на 02.12.2025 — будем говорить про работу с состоянием и внешние системы (7-8 главы)

Ещё раз извиняюсь за перенос со вторника(

Источники:
- Репозиторий с примерами к книге — полная версия только для Scala
- 3 выпуск по “The Dataflow model” — в нём обсуждали концепции время, watermark и компоненты модели, реализации которых приводятся в выпуске

#in_the_flow #flink #streaming