Я хочу применить ProcessFunction () к потоку входных данных в Flink, чтобы обработать каждый...

Я хочу использовать личную переменную в моей работе Flink (Scala) для параллельных задач Flink.Мой...

Я хочу найти шаблон событий, которые следуют Внутренний шаблон: Имеют то же значение для клавиши...

У меня есть потоковое задание flink, которое читает из Kafka и записывает в соответствующие разделы...

Я запускаю простую потоковую работу, где вычисляю почасовые показы для кампаний: .keyBy(imp =>...