apache-flink

1зной

1ответ

Флинка потоковый: Поток данных, который получает под контроль поток управления

У меня есть вопрос, который является разновидностью этого вопроса: Flink: how to store state and use in another stream? У меня есть два потока: val ipStream: DataStream[IPAddress] = ??? val routeStrea

1зной

3ответ

Флинк с Kafka как источник

Я пытаюсь прочитать данные из темы kafka, в потоке Flink. Я пытаюсь запустить следующий пример кода, который существует в качестве примера на странице APACHE FLiNK 1.1.3 Документация: разъем Apache Ка

0зной

1ответ

Флинк: использование метки времени, которая включена в сообщение для оконного окна EventTime

Я принимаю сообщение от стримера Кафки во Флинк. В сообщении есть поле Record_time, и я хочу применить временное окно на основе Record_time. Могу ли я извлечь или использовать поле Record_time, чтобы

0зной

2ответ

Как API Apache-Flink читает CSV-файл, используя параллелизм под капотом?

Я использую функцию readCsvFile (path) в Apache-Flink api, чтобы прочитать CSV-файл и сохранить его в переменной списка. Как это работает, используя несколько потоков? Например, он разбивает файл на о

1зной

1ответ

Флинк: Оценка окон

Я использую window(SlidingEventTimeWindows.of(Time.seconds(120), Time.seconds(1))) скользящее окно для потоковой передачи данных real_time. Я также использую интерфейс AssignerWithPeriodicWatermarks д

0зной

1ответ

Flink redis connector: обновить getCommandDescription() после создания экземпляра

Я использую радиатор Refink Redis для записи некоторых счетчиков на redis. Я хотел бы создать HASH для каждого дня, однако getCommandDescription() для раковины только вызывается один раз при создании

0зной

1ответ

RuntimeException при использовании MapFunction Flink с Cassandra «Insert», но не с «Statement»

При экспериментировании с потоковой передачей Flink вместе с Cassandra у меня возникла интересная проблема при попытке генерировать инструкции INSERT в MapFunction. Если бы я использовал DataStream<In