Я использую структурированную потоковую обработку для чтения входящих сообщений из темы Kafka и...
Spark Streaming Job считывает данные о событиях из тем Кафки, агрегирует на основе меток времени и...
У меня есть задание потоковой передачи, которое считывает данные из нескольких тем Кафки.Теперь я...
Я пытаюсь прочитать тему Kafka из кластера Spark с использованием API-интерфейса структурированной...
Попытка разобраться в SparkSql относительно структурированной потоковой передачи Spark.Spark...
В нашем приложении мы используем структурированную потоковую передачу с MapGroupWithState в...
Я немного новичок в Scala и Spark, поэтому не стесняйтесь судить меня, но не слишком сложно. Я...
В моем сценарии у меня есть несколько наборов данных, которые приходят время от времени, и которые...
У меня есть вопрос относительно структурированной потоковой передачи Spark в потоке Kafka. У меня...
Я пытаюсь выполнить тестовые случаи из spark-testing-base , я пытаюсь выполнить этот тест, но по...
Я хотел бы понять следующее: В структурированной потоковой передаче Spark существует понятие...
Мое приложение структурированной потоковой передачи пишет в паркет, и я хочу избавиться от...
У меня есть потоковое потоковое приложение, которое читает данные из Kafka и записывает их в базу...
Я пытаюсь прочитать поток из kafka, где значение представляет собой строку значений, разделенных...
Я пытаюсь загрузить потоковый фрейм данных Spark, используя структурированную потоковую передачу, и...
В некотором роде пост , который у меня был месяц назад.У меня есть искробезопасное приложение для...
Я пытаюсь использовать защищенную тему Кафки (используя SASL_PLAINTEXT, метод ScramLogin). Spark...
Я использую Spark Structured Streaming для записи в Elasticsearch 6.2.0 Sink: dataDf .writeStream
Интересно, есть ли где-нибудь список всех свойств, связанных с потоковой структурой с искрой?...
Насколько я понимаю, структурированная потоковая передача Spark основана на Spark SQL, а не на...
Как использовать потоковую обработку spark strcutured для пакетных запросов, как мне прочитать...
У меня есть простая программа Spark-SQL-Kafka, которая читает из Kafka и пишет в HDFS. Для проверки...
Из-за того, что структурированные потоки Spark являются довольно новым API, возникают ситуации,...
У меня есть данные, которые постоянно передаются в корзину S3. Я хочу настроить приложение...
Я пытаюсь подключиться к Kafka с помощью потоковой структурированной искры. Это работает:...