Я читаю из кластера Kafka в потоковом приложении Flink. После получения исходного потока я хочу...

У меня есть KeyedStream для разделения потока событий по ключу. Каждый поток с ключами будет...

Я попытался создать тестовое задание scala для чтения потоковых данных kafka с помощью потокового...

Я определяю определенные переменные в одном Java-классе и обращаюсь к нему с помощью другого класса...

Мы ищем решение для мониторинга нашего потока данных - отслеживание хода входящих сообщений во...

Контрольные точки с источником в качестве EventHub с поддержкой kafka имеют тенденцию к превышению...

KeyedProcessFunction требует, чтобы предыдущий оператор был оператором keyedBy Когда я пытаюсь...

В качестве одного из моих последних шагов в потоковом приложении я хочу отсортировать...

Я намерен зарегистрировать таблицу с БД и информацией о таблице соответственно как: tableEnv

Я пытаюсь сохранить свои контрольные точки в хранилище больших двоичных объектов.Согласно...

Когда я запустил простое приложение Flink с KeyedStream, я заметил, что время задержки события...

У нас есть пакетные конвейеры, записывающие файлы (в основном csv) в корзину s3.Некоторые из этих...

Учтите, что мы собираемся вычислить среднее число датчиков температуры за данный период времени, и...

Обучение использованию Flink (1.8.0) с Python, попытка прочитать тему Кафки. Использование кода из...

Я хочу настроить кластер Apache Flink с несколькими компьютерами, и просто хочу знать, запущен ли...

У меня есть требование генерировать событие CEP, если мы обнаружили, что строковое сообщение...

Мы рассматриваем возможность использования flink для использования, но не уверены, подходит ли ему...

Я реализую функцию RichParallelSourceFunction, которая читает файлы через SFTP....

У меня есть несколько паркетных файлов, которые я прочитал в потоковом приложении Flink, чтобы...

В документации Flink для RichAsyncFunction указано: API-интерфейсы, относящиеся к состоянию в...

Кто-нибудь знает, как проверить оконные функции в Flink?Я использую зависимость flink-test-utils_2

Предоставляет ли flink способ периодически запрашивать API и создавать из него объект потока данных...

Я работаю над приложением , которое загружает некоторые файлы в корзину s3 , а позже читает файлы...

Я пытаюсь настроить флинк для восстановления с контрольных точек.По большей части это, похоже,...

Для случая одной итерации итеративного цикла, когда тип обратной связи отличается от типа входного...