Для построения запросов потоковой обработки было рекомендовано (одним из членов команды), чтобы мы...

Я читаю сообщения от Кафки в оболочку Flink Scala. Я хочу прочитать несколько сообщений, сохранить...

Я пытаюсь подключиться и читать с Kafka (2.1) на моем локальном компьютере, в оболочке scala,...

У меня есть сценарий с приложением flink, которое получает потоки данных в следующем формате:...

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

Я пытаюсь портировать приложение Apache Flink (scala) на структурированную потоковую передачу Spark

JobManager HA очень важен для Flink и задокументирован здесь .Тем не менее, документация больше...

Я использую Apache Flink 1.7.1. У меня есть некоторые свойства в файле YAML, такие как: cassandra:...

Я пытаюсь сделать экспоненциально убывающую скользящую среднюю по скользящему окну в Flink SQL.Мне...

Теперь у нас есть SQL с причудливым управлением окнами во Flink, я пытаюсь, чтобы затухающая...

Насколько я знаю, Kafka Streams обрабатывает свои состояния локально в памяти, на диске или в теме...

Я работаю над приложением на основе Apache Flink, которое использует Apache Kafka для ввода и...

Я настроил PrometheusPushGatewayReporter, как описано в разделе метрик документации. Я вижу...

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

Я использую потоки мерцания в микросервисной архитектуре для передачи данных ETL из сервисов в базы...

Я пытался создать и ExternalCatalog для использования в Apache Flink Table. Я создал и добавил в...

Я использую аккумулятор в функции сгиба.Я хотел бы изменить значение аккумулятора. Моя функция...

Я успешно использую JsonRowSerializationSchema из артефакта flink-json для создания...

В настоящее время я работаю над семестровым проектом, где я должен узнать серию из трех событий....

Я определил линию потоковой обработки с помощью Apache Beam и собрал ее для бегуна Fling. Я получил...

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

Я создал очень простое задание Apache Beam для теста, оно написано в Scala и выглядит так: object...

Я не был уверен, почему логический план не был правильно оценен в этом примере . Я посмотрел более...

Я пытаюсь запечь очень простой конвейер, который читает поток событий из Kafka (KafkaIO.read) и...

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