Если два потока событий во Flink, они могут быть логически объединены с использованием информации в третьем событии, которое следует за ними (с использованием API DataStream или CEP)? Например, может
Я пытаюсь распечатать строку, если Hello и world найдены с использованием библиотеки Flink CEP. Мой источник - Kafka и с помощью консоли-производителя для ввода данных. Эта часть работает. Я могу расп
Библиотека СЕР позволяет легко написать программу, чтобы описать, что можно сказать, если X следует Y. val pattern = Pattern.begin("start").where(_.value == "X") .next("end).where(_.value == "Y") Но к