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

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

У меня есть источник потока, и я сначала пытаюсь получить модель K-средних кластеризации.Позже я...

Я хочу заменить строку «a» для массива строк, делая .contains () для проверки каждой строки в...

У меня есть процесс Spark Streaming, который отключает записи тема Кафки, обрабатывает их и...

Я хотел бы выполнить последовательность действий над DStream.Действие N + 1 должно выполняться...

object abc { def main(args: Array[String]) = { m() } def m() { val spark = SparkSession.builder

Я пытаюсь выполнить операцию отображения на Spark DStream в приведенном ниже коде: val...

У меня есть сценарий использования для генерации суррогатного ключа (уникального и с приращением 1)...

Привет всем: я обнаружил проблему в своем кластере с искровым потоком. Мы собираем потребителя,...

У меня есть данный кусок кода. Я запускаю это на Spark 2.3.1, используя Zeppelin 0.8.0 и org.apache

Доступна ли вкладка потоковой передачи для готовых приложений потокового воспроизведения. Можем ли...

Чтобы создать СДР в Spark Streaming, как мне оценить правильный интервал между партиями, чтобы мои...

У меня есть поток изменений Mongo (приложение pymongo), который постоянно получает изменения в...

Я получаю исключение AbstractMethodError при создании JavaStreamingContext. Моя зависимость от pom,...

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

Мы разрабатываем приложение Spark Streaming, получающее данные (события аутентификации) из раздела...

Я пытаюсь отслеживать приложения для потоковой передачи с использованием jmx. Но для настройки...

Нам нужно было реализовать объединение по темам Kafka с учетом поздних данных или «не в соединении»...

Программа My Spark Streaming получила следующую ошибку: Исключение в потоке "main" java.lang

В нашем приложении spark мы используем поток Kafka и храним данные в Cassandra DB. Во-первых, мы...

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

У меня есть входные данные, такие как: id operation value 1 null 1 1 discard 0 2 null 1 2 null 2 2...

У меня есть приложение SparkStreaming, читающее сообщение от kafka, все данные задачи процесса с...

Я использую Stream-Streaming (версия 2.2) в кластере пряжи и пытаюсь включить динамическое...