Я пытаюсь выполнить код Python внутри программы Scala. Все отлично работает локально на машине с...

Я использую Cassandra 3.11.4 и Spark 2.3.3.Когда я запрашиваю множество ключей раздела (в течение 3...

У меня есть следующий фрейм данных: +--------+------+---------+---------+ | Col1 | col2 | values1 |...

У меня есть два кадра данных A и B. A +---+------+-----+----------+ | id|player|score| date|...

Я читаю из kafka с использованием искровой структурированной потоковой передачи, ниже мой поток...

Я использую Билайн для выполнения hql-запросов.Задание не отображается в диспетчере ресурсов для...

Я пытаюсь выполнить действие с помощью Spark с зависанием.Соответствующий исполнитель выдает...

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

Я реализую источник данных Spark (v2) и не нашел способа обеспечить локальность данных. В источнике...

В пользовательском интерфейсе Spark тег этапа показывает задачи и DAG https://www.waitingforcode

Мы используем кластер с открытым исходным кодом Apache spark, и у меня есть следующий...

У меня есть два кадра данных, которые имеют общие имена столбцов. df1 -> ID, имя, адрес, отдел df2...

Мы собираем потоковые данные с устройства (Android, iOS).Поток данных: websocket -> logstash ->...

У меня есть шаблон Аккумулятор, который я хочу разбирать, как мне это сделать? val patternsAcc = sc

У меня установлено приложение Spark Streaming, которое использует тему Kafka, и мне нужно...

Я использую pyspark и Flask для интерактивной искры в качестве сервисного приложения. Мое...

Моя проблема в том, что я не понимаю, что представляет собой «зарезервированные vcores», и как он...

Как я понимаю, Apache Spark Master можно запустить в режиме высокой доступности с помощью Zookeeper

Я работаю над настройкой, включающей Apache Spark.Проблема сейчас в том, что не всем пользователям...

Я обучил LDA (размерность объекта: 100, итерация: 100, Распределенная версия, мл) с использованием...

Я не могу использовать MQTTUtils.createPairedStream () в Скале? Как указать список тем в качестве...

Как реализовать метод readSchema () в DataSourceReader в случае обрезки столбцов? Метод readSchema...

Я экспериментировал с тем, какие максимальные необработанные данные я могу кэшировать, не влияя на...

Я использую pyspark для генерации фрейма данных, в котором мне нужно обновить столбец 'amt'...

У меня есть таблица улья, которая имеет около 2500 столбцов, когда я читаю ее с помощью spark sql...