Вопросы с тегом искра-структурированного-потоковое

0 голосов

0 ответов

Как в Spark предотвратить многократное копирование файла Jar с помощью dynamicAllocation

caverman / 04 мая 2020

0 голосов

0 ответов

Разблокировка вызовов API с использованием искровой структурированной потоковой передачи

irrelevantUser / 03 мая 2020

0 голосов

0 ответов

Интерфейс Spark для структурированной потоковой передачи, показывающий дублированные запросы sql

Funzo / 01 мая 2020

0 голосов

0 ответов

Запрос Spark Structured Streaming: java .lang.AssertionError: утверждение не выполнено: опция удаления только контрольной точки?

it243 / 01 мая 2020

0 голосов

1 ответ

Spark структурированная потоковая агрегация в реальном времени

Jeremie Piotte / 30 апреля 2020

0 голосов

1 ответ

Как применить схему Spark к запросу на основе имени Kafka topi c в структурированной потоковой передаче Spark?

TechnocratSid / 29 апреля 2020

0 голосов

1 ответ

Как сделать так, чтобы спарк-структурированный поток обрабатывал все данные в kafka

Jeremie Piotte / 29 апреля 2020

2 голосов

0 ответов

Spark структурированный поток с аутентификацией Kafka SASL / PLAIN

user152468 / 28 апреля 2020

2 голосов

0 ответов

Как лучше рассчитать скользящие метрики, которые охватывают партии в структурированной потоковой передаче Spark?

ppranger / 23 апреля 2020

0 голосов

2 ответов

PySpark структурированная ошибка Streaming + Kafka (вызвано: java .lang.ClassNotFoundException: org. apache .spark. sql .sources.v2.StreamWriteSupport)

Petro Hupalo / 22 апреля 2020

0 голосов

0 ответов

Режим добавления вывода не работает в структурированной потоковой передаче Spark с приемником foreach

user3553913 / 19 апреля 2020

0 голосов

1 ответ

java .lang.NoSuchMethodError: org. apache .spark.internal.Logging. $ Init $

naina / 16 апреля 2020

0 голосов

1 ответ

Spark Structured Streaming чтение из нескольких тем Kafka с несколькими потоками чтения

Dhatri / 13 апреля 2020

2 голосов

1 ответ

Структурированный поток: чтение из нескольких тем Kafka одновременно

Siddharth Goel / 13 апреля 2020

0 голосов

1 ответ

Как использовать foreachPartition в Spark?

Maria / 12 апреля 2020

0 голосов

0 ответов

Неправильный выход при структурированной искровой струе

NIK_NAME / 09 апреля 2020

0 голосов

0 ответов

Выполнение нескольких запросов в Spark структурированном потоке с водяными знаками и оконными агрегатами

Siddharth Goel / 09 апреля 2020

0 голосов

1 ответ

pyspark. sql .utils.AnalysisException: 'Время события должно быть определено в окне или отметке времени, но отметка времени имеет тип string

littlely / 09 апреля 2020

0 голосов

1 ответ

Apache Spark непрерывно загружает данные с одного URL

alexanoid / 08 апреля 2020

1 голос

1 ответ

Что означают эти показатели для структурированной потоковой передачи Spark?

Machi / 07 апреля 2020

0 голосов

0 ответов

Spark 2.3.1 Как установить условие диапазона времени события для структурированного потокового внутреннего соединения

on_the_shores_of_linux_sea / 04 апреля 2020

1 голос

1 ответ

Соответствует ли идентификатор раздела Kafka Topi c, которому было отправлено сообщение, идентификатору раздела открытого метода в ForeachWriter?

Chirag / 02 апреля 2020

0 голосов

1 ответ

Spark Структурированная потоковая передача foreach Пользователь Sink не может читать данные из раздела Кафки.

Usman Azhar / 01 апреля 2020

1 голос

1 ответ

Как найти идентификатор группы потребителей потокового приложения с искрой?

Machi / 31 марта 2020

0 голосов

1 ответ

Spark - структурированная потоковая кафка (динамическая c десериализация)

Raman / 28 марта 2020