У меня есть кортеж (Float, String) потока данных, который я бы хотел отсортировать и выбрать три самых больших значения для каждого timewindow (фиксированного). Окно потока данных - это время обработк
Я пытаюсь протестировать программу Flink, чтобы прочитать данные JSON, полученные от Kafka, используя этот класс JSONKeyValueDeserializationSchema. Однако мой Intellij не находит этот класс. Я подозре
Я пытаюсь получить JSON от темы Кафки с этим кодом: public class FlinkMain {
public static void main(String[] args) throws Exception {
StreamExecutionEnvironment env = StreamExecutionEnvironment