Вопросы с тегом искровой-потоковый

0 голосов

1 ответ

Как динамически разделить данные в этом сценарии использования

Shyam / 03 марта 2020

0 голосов

0 ответов

Не получается вывод в SparkStreaming

Maria / 29 февраля 2020

0 голосов

1 ответ

разница потоков между столбцами A и B, агрегированная по столбцам C и D

storis / 29 февраля 2020

0 голосов

0 ответов

Физическая интерпретация исторической ошибки в PIDRateEstimator

Yik San Chan / 27 февраля 2020

0 голосов

1 ответ

Получение java .lang.NoSuchMethodError при отправке искрового задания

Pawan Kumar / 26 февраля 2020

0 голосов

0 ответов

Несколько потоковых агрегатов не поддерживаются потоковыми наборами данных / наборами данных

Mayank Metha / 23 февраля 2020

0 голосов

0 ответов

Spark Streaming: сколько пакетов обрабатывается после корректного завершения работы

mike / 23 февраля 2020

0 голосов

0 ответов

ElasticSearch: поведение API Spark Java: JavaEsSpark.saveToEs (фоновый или нет)

Sebastien / 20 февраля 2020

0 голосов

0 ответов

Прошлая партия в Spark Streaming

Hrishikesh Mishra / 20 февраля 2020

0 голосов

1 ответ

Является ли естественная замена потоковой передачи Spark (Direct) потоковой структурой Spark или потоками Kafka?

mike / 20 февраля 2020

0 голосов

1 ответ

Dtream to Rdd в Искорно-Страминге

Daniel Carretero / 19 февраля 2020

0 голосов

0 ответов

Spark Streaming не выбирает новые файлы из облачного хранилища

durgaprasad jr / 17 февраля 2020

0 голосов

1 ответ

Запись данных из кафки в улей с помощью pyspark - застрял

Jay / 16 февраля 2020

0 голосов

0 ответов

Как обрабатывать / запускать элементы списка параллельно в spark?

Shyam / 14 февраля 2020

1 голос

1 ответ

Получение: Ошибка импорта модулей Spark: нет модуля с именем «pyspark.streaming.kafka»

Reeja / 12 февраля 2020

1 голос

1 ответ

Кафка createDirectStream с использованием PySpark

Soumya / 12 февраля 2020

0 голосов

0 ответов

ОШИБКА BlockGenerator: Ошибка в потоке, проталкивающем блок java .util.concurrent.TimeoutException: Время ожидания фьючерса истекло после [30 секунд]

Shruti / 09 февраля 2020

1 голос

1 ответ

Scala регулярное выражение для хэштегов

ZiZ0GaminG / 31 января 2020

0 голосов

1 ответ

Spark Streaming для обновления SQL Сервер (транзакция)

Sandeep reddy / 29 января 2020

0 голосов

1 ответ

Ровная семантика в прямом подходе Spark Streaming

Sheel Pancholi / 26 января 2020

0 голосов

1 ответ

Ошибка API Spark Twitter

Swastik / 25 января 2020

0 голосов

0 ответов

Получение org. apache .spark.SparkException при отмене сопротивления RDD в искре

Deepank Porwal / 23 января 2020

0 голосов

1 ответ

как получить доступ и объединить несколько типов DataFrame of Future в scala

saurabh srivastava / 22 января 2020

2 голосов

0 ответов

Невозможно сохранить использованные смещения Kafka в таблице HBase при фиксации через Spark D Streams

Mohit Raja / 18 января 2020

1 голос

0 ответов

Фиксировать смещения после обработки нескольких потоков в потоковой передаче искры

wandermonk / 16 января 2020