У меня есть кортеж (Float, String) потока данных, который я бы хотел отсортировать и выбрать три самых больших значения для каждого timewindow (фиксированного). Окно потока данных - это время обработк
Я пытаюсь перенести пример SlidingArrivalCount.scala, основанный на Flink 0.10.1 на Flink 1.1.1. Источник данных источника данных TaxiRideSource, используемый в примере, реализует интерфейс org.apache
Я пишу прототип приложения, используя Apache Flink. В этом процессе я решил использовать org.apache.flink.streaming.api.functions.windowing.WindowFunction для конкретного примера использования. Однако