Я выполняю задание потоковой передачи в режиме кластера пряжи.Это приведет к получению записей из...
Используют ли Spark Streaming и Spark Structured Streaming один и тот же механизм...
Я пытаюсь использовать поток кинезиса и выполнять преобразования на нем с помощью потоковой искры,...
Мы используем безключевую клавиатуру для запуска долго работающего приложения с потоковым искром
У меня есть структурированная потоковая передача Spark, которая читает события пользовательского...
Я пробую структурированную потоковую передачу в Azure Databricks, используя хранилище Databricks...
Я пытаюсь настроить автоматическое масштабирование для наших заданий Spark Streaming, выполняющихся...
Я пытаюсь записать набор данных Spark Structured Streaming (2.3) в ScyllaDB (Cassandra). Мой код...
В документации по https://spark.apache.org/docs/latest/structured-streaming-programming-guide
Как я могу вычислить агрегации в окне от датчика, когда новые события отправляются, только если...
Я запускаю потоковое приложение в кластере, состоящем из трех узлов, каждый из которых имеет своего...
Просто общий вопрос, у меня есть приложение для потокового воспроизведения, которое получает данные...
У меня есть продолжительное приложение для потоковой передачи искры (режим клиента пряжи, EMR),...
Я получаю поток данных в форме: +--+---------+---+----+ |id|timestamp|val|xxx |...
Вот мой код: ssc =streamingcontext(sparkcontext,Seconds(time)) spark = sparksession.builder
Интересно, как работает честный планировщик с Spark (структурированным) Streaming при работе на...
Из-за того, что структурированные потоки Spark являются довольно новым API, возникают ситуации,...
в настоящее время моя структурированная потоковая передача Spark работает следующим образом...
Я пробовал и API-интерфейс spark batch, и API-интерфейс структурированной потоковой передачи, но я...
Как Spark структурированная потоковая передача сообщает приемнику, что новая строка является...
Как сравнить полученную запись с предыдущей записью того же ключа в искровой структурированной...
Я пытаюсь прочитать сообщения из очереди Amazon SQS. Разрешения работают, я вижу количество записей...