Spark 1.6 scala Как сохранить вывод в csv-файл spark 1.6. Я сделал что-то подобное. myCleanData

Я установил doobie + hikaricp с настройками, аналогичными настройкам по умолчанию.С помощью журнала...

У меня есть «Структурированные данные», как показано ниже, мне нужно преобразовать их в показанный...

Я обучаю и сохраняю модель XGBoost, как показано ниже: Версия XGBoost 0.82 Версия Spark 2.4.2...

Я знаю, если я хочу преобразовать xs: RDD[Option[T]] to List[T], я просто пишу xs.flatten Теперь,...

У меня есть файл .csv, который я пытаюсь проанализировать с помощью spark.Файл .csv содержит,...

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

Я читаю Функциональное программирование в Scala и занимаюсь 5-й главой, посвященной строгости и...

Мне нужно найти все недели года между указанными неделями. 201824 - это пример годовой недели.Это...

Довольно плохо знаком с scala. У меня есть оператор if else, который на основе условия присваивает...

Мне нужно взять карту [String, DataFrame] и преобразовать ее в набор данных [Map [String, Array]]...

Пример данных У меня есть набор данных, который выглядит ниже и представлен в текстовом формате:...

Я использую Scala в своем проекте и хочу интегрироваться с Stripe, но он предоставляет только Java...

Применяет MAP () к Dataframe, всегда преобразует DF в RDD. scala> val custDF = sqlContext.read

Я практикую проблему со Spark, используя Scala, и у меня есть таблица футбольной лиги со столбцами...

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

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

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

Примечание: предложения, приведенные в ответах на следующие вопросы, не работают значение toDF не...

У меня есть фрейм данных со строковым столбцом: day и другими столбцами.Я хочу сделать что-то вроде...

Я использую Модуль Джексона Scala , чтобы попытаться сериализовать и десериализовать классы случаев...

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

var countryMap = Map("Amy" -> "Canada", "Sam" -> "US",...

У меня есть актер Akka FSM, состояние которого определяется как перечисление Java: TheState.java...

Я хочу преобразовать пустые значения, вложенные в массив строк, в пустые строки в искре.Данные...