Я пытаюсь интегрировать Apache Kafka 2.11-0.10.0.0 с Apache Flink 1.1.2. Я использую scala-shell, чтобы проверить его, и я получаю следующую ошибку. Класс org.apache.flink.streaming.api.checkpoint.Che
Я расчета счетчик (суммирующий 1) по timewindow следующим образом: mappedUserTrackingEvent
.keyBy("videoId", "userId")
.timeWindow(Time.seconds(30))
.sum("count")
Я хотел бы на
Я пытаюсь распечатать строку, если Hello и world найдены с использованием библиотеки Flink CEP. Мой источник - Kafka и с помощью консоли-производителя для ввода данных. Эта часть работает. Я могу расп
Мне поручено перепроектировать существующий процессор для каталога, и требование идет как ниже. Требования: у меня есть от 5 до 10 поставщиков (каждый поставщик может иметь несколько магазинов), котор