Я пытаюсь настроить zeppelin-0.8.0 на моей операционной системе windos 8 r2.У меня уже есть спарк...

Я использую структурированную потоковую передачу Spark для чтения файлов, поступающих в мою систему...

Я могу подключиться к улью, используя hive.metastore.uris в Sparksession.Я хочу подключиться к...

Я следую инструкциям по созданию потокового куба из Куб Килина от Streaming (Кафка) Все свойства...

Я определил приложение Spark для потребителей и производителей Kafka. Однако сообщения не попадают...

У меня ошибка при запуске примера StructuredNetworkWordCountWindowed. Error: org.apache.spark.sql

Я читал несколько вопросов по этой теме, а также несколько форумов, и во всех них, похоже,...

У меня есть программа структурированного потокового вещания на основе scala, которая должна...

Когда я пытаюсь вычислить площадь многоугольника, представленную как WKT POLYGON((35.76171875 62

Я пытаюсь прочитать структурированный поток, поток состоит из статистики ping: 64 bytes from vas

Здесь я отправляю данные json в kafka из темы «test», передаю схему json, выполняю некоторые...

Я ищу решение для добавления значения временной метки kafka в мою схему структурированной потоковой...

Я установил кластер Apache Spark с мастером и одним рабочим, и я использую Python с Spyder в...

Кто-нибудь, кто работает с платформой Palantir Foundry? Я работаю в области интеграции и анализа...

Я использовал to_avro для сериализации поля структуры в dataframe в 'value' и записи в тему kafka....

Я записываю фрейм данных в своем коде с , опция 1: finaloutput.repartition(200).write

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

Я читаю искру CSV. Я предоставляю схему для файла, который я читаю, и я читаю его в разрешающем...

У меня есть отсортированный набор данных с разными столбцами и идентификатором. Набор данных...

У меня есть небольшой автономный кластер spark с динамическим распределением ресурсов, который...

Когда я пытаюсь запустить потоковое приложение Spark с интеграцией Kafka, я получаю эту ошибку:...

Я пытаюсь вставить данные из Кафки в Кассандру, используя 1 узел искры и 1 узел Кассандры.Фрагмент...

У меня есть два Spark DataFrames: cities DataFrame со следующим столбцом: city ----- London Austin...

У меня есть две следующие схемы паркета: users: -------------------- |user_id | username|...

Я настроил кластер головного узла. Я успешно интегрировал ноутбук Jupyter с ним. ( Используя этот...