Я предоставляю пользователям интерфейс Flink SQL, поэтому я не могу использовать интерфейс Table...

Кафка очень распространена.Так много компаний используют это.Я полностью понимаю, как работают...

Я пытаюсь понять, что на самом деле делает Флинк, но сейчас немного запутался. Давайте посмотрим на...

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

Я хотел бы задать вам один простой вопрос.Когда я использую архитектуру Kappa Big Data, она...

Чем переворачивающееся окно в 5 секунд при обработке потока отличается от микропакета в 5 секунд...

У меня есть данные, которые слишком велики для одного сообщения.Рассмотрим avro: record Likes {...}...

Я хочу реализовать довольно простую группу обеспечения доступности баз данных в RxJava. У нас есть...

Мы разрабатываем сервис потоковой обработки, который идет из Кинезиса во Флинк. Службе потребуется...

Допустим, у меня есть поток событий. R1 - {"abc": "значение 1"} R2 - {"abc": "значение 2"} R3 -...

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

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

Скажем, я хочу вычислить среднее значение определенного показателя за последние 10 минут после...

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

Я новичок в Kafka, и я хотел бы знать, возможно ли и разумно ли реализовать то, что я планирую...

Недавно была выпущена стабильная версия (1.6.2) apache flink.Я прочитал эту инструкцию .Но когда я...

У меня есть приложение kafka stream, работающее с 36 различными экземплярами (по одному для каждого...

Окно по сеансам из раздела просмотров страниц в KafkaStreams, логика агрегации может разбить сеанс...

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

Я пытаюсь подключить тему Kafak, в которой используется Avro, к Spark Stream.Я пытаюсь использовать...

У нас есть поток Кафка, который использует Avro.Мне нужно подключить его к Spark Stream, используя...

У меня есть FlinkKafkaConsumer11 с регулярным выражением.Он слушает существующие темы,...

У нас есть топология потоков, которая будет работать на нескольких машинах. Мы храним результаты...

Я сравниваю Apache Beam SDK с Flink SDK для потоковой обработки, чтобы определить стоимость /...

Я создаю приложение Kafka Streams, которое генерирует события изменений, сравнивая каждый новый...