В предыдущей части автор разобрал оператор с Flink-таймерами и показал, как тестировать его с помощью TestHarness, Flink MiniCluster и E2E-тестов.
В этой статье рассматривается сериализация данных в операторах и написание своего сериализатора, поддерживающего эволюцию схемы.
⛓ Ссылка на статью
🔖 Предыдущая часть — КЛИК
📱 Java Developer | #статья