У меня запущена программа spark mlib, которая применяет nlp к свободному тексту. Мне нужно было бы...

Я в Windows 10 пытаюсь несколько раз прочитать текстовые строки, отделенные '\n' от...

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

Мой вопрос касается Spark Streaming и столбца, который является JSON и столбца func_params. но, как...

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

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

Я использую kudu и spark streaming для панели мониторинга в реальном времени, моя проблема в том,...

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

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

Мы используем Spark Streaming (Java) для вычислений в реальном времени. Развертывание имеет...

В моем проекте мы используем kakfa с поддержкой Stream Streaming, для PoC я использую версию spark...

Я хочу сделать несколько потоковых упражнений, как получить хороший источник потоковых данных? Я...

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

Хотите отследить сообщение kafka внутри Apache Spark У меня запущено приложение Spark Streaming,...

Существует искровое приложение с двумя агрегирующими шагами, за которыми следует внутреннее...

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

я использую spark 1.6 в intellij со scala Я пытаюсь создать потоковое приложение код: import domain

Я создал искровое приложение, которое получает входные данные из Apache Flume.Я установил интервал...

У меня есть программа Apache Spark Streaming, которая передает данные каждый раз, когда они...

Я использую Spark 2.3 (HDP 2.3.0.2.6.5.108-1) и Spark Streaming (JavaInputDStream). Я пишу тест...

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

hasTimedOut метод никогда не true в моей функции обработки произвольного состояния updateState def...

Я должен использовать загрузку файла один раз в день и использовать это в моей потоковой передаче....

Я использую spark stream и читаю один файл из папки hdfs.Один и тот же файл обновляется другим...

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