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

Я абсолютный новичок в Scala и хотел бы создать все возможные комбинации элементов списка, но пока...

У меня есть как DataFrame со строковым столбцом val df=...

У меня есть датафрейм с двумя столбцами с данными, как показано ниже +----+-----------------+...

Я исследую реализацию мониторинга JMX и хотел узнать, как сервер JMX MBean управляет памятью и...

Извините за вопрос noob, у меня в SparkSQL есть такой фрейм данных: id | name | data...

Я пытаюсь обработать XML-файл, используя scala и spark. У меня есть эта схема: root |-- IdKey: long...

Как я могу обновить столбец m_name с помощью алгоритма Левенштейна, чтобы заменить нули?...

Я пытаюсь запустить простую запись данных в пример ElasticSearch. Тем не менее, я получаю эту...

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

Мне нужно иметь возможность зарегистрировать udf из строки, которую я получу от веб-службы, т.е. во...

Я пытаюсь преобразовать следующий класс дел в / из JSON с помощью Spray: case class Interval(lower:...

Я прошел через документацию Reddit API. Я должен сделать веб-приложение (не сценарий) Снимок экрана...

У меня есть следующий код, написанный с использованием Cats IO, который выполняет несколько...

Дорого ли бросать исключения в Scala? Более конкретно, при отображении исключений для будущего...

Я использую IntelliJ для ускорения разработки приложений Spark в Scala с использованием sbt.Я...

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

У меня есть два кадра данных: edges = srcId dstId timestamp 1 4 1346564657 1 2 1345769687 2 4...

Это мой фрейм данных без формата данных...

Использование Spark Streaming для чтения и обработки сообщений от Kafka и записи в HDFS - Hive. Так...

образец линии: { "расширение": "имена, схемы", "centralid": 10, "centralloc": "Балх", компоненты: [...

Я работаю с фреймами данных в Scala в банковском процессе, и мне нужно удалить некоторые строки,...

У меня есть несколько искровых тестов, которые я нормально выполняю удаленно через maven на spark 1

У меня есть код ниже val c: RDD[(String, String)] = graph.triplets.map( triplet => { if (triplet

Я хотел бы проверить данные существующего столбца и создать новый столбец на основе определенных...