В проекте Scala, в котором есть задание Spark, я использовал соединитель Spark-Hbase (SHC) для...

Если по какой-то причине нам необходимо отключить кластер kafka и с помощью искровой потоковой...

В нашем проекте мы рассматриваем возможность использования kakfa с потоковой передачей Spark, для...

Я не смог найти документацию, рассказывающую, как использовать spark-streaming-kafka-0-10_2.10 с...

Я должен реализовать управление смещением в Spark для потокового задания на Java, которое читает из...

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

У меня есть 2 потоковых запроса, как показано ниже val streamingQuery = injectableDependencies

Я использую PostGre в качестве базы данных.Я хочу захватить одну таблицу данных для каждого пакета...

Я переключаю приложение с потоковой передачи на структурированную. Это приложение для чтения логов...

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

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

Я сталкиваюсь с ошибками при попытке индексировать несколько документов в solr с помощью...

Я управлял брокером зоопарка и кафкой, но я не руководил производителем кафки.Я запустил код...

Мои данные находятся в PubSub, и я хочу передать данные. Я использую dataproc, чтобы запустить мое...

WARN TaskSchedulerImpl: начальное задание не приняло никаких ресурсов; проверьте интерфейс кластера...

Я потребляю твиты для Кафки-продюсера, а затем поглощаю их для Кафки-потребителя.Я могу заставить...

Я транслирую твиты из приложения Twitter в Spark для анализа. Я хочу вывести итоговую таблицу Spark...

Существует ли какой-либо другой более простой подход для вычисления нескольких политик истечения...

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

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

Я получаю не сериализуемое исключение при попытке получить и записать значение в HDFS, используя...

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

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

версия spark: 2.3.0 версия python: 3.7 и также пробовал 3.4. при запуске кода ниже в spark-submit с...

Мое приложение использует и обрабатывает сообщения Kafka, используя Spark Streaming, используя...