Spark Scala для selectExpr выдает исключение...

Я извлекаю zip-файлы в памяти, используя команду scala, как показано ниже: val rdd = sc

У меня есть СДР, groupResultMap, и напишите код ниже. if (groupResultMap.isEmpty) Map[String,...

У меня есть таблица с двумя столбцами, один - идентификатор, а другой - значение. Мой столбец...

Я пытаюсь переместить проект scala с sbt 1.2.7 на 1.3.3, и есть много ошибок. Один из них - value...

Мне нужно сделать проверку безопасности для моего приложения. Я написал этот код для загрузки всех...

У меня есть простые методы: def retrieveRepositories(url: String, params: String): IO[HttpResponse]...

Я новичок в Scala и пытаюсь выяснить, как я могу перенаправить свои журналы в файл в Scala. Это...

У меня есть простой код: override def createContributorsList(url: String, params: String):...

Я использую блоки данных Azure и хочу отправить запрос к Azure SQL с помощью PySpark. Я пробовал...

У меня есть классы дел в приложении Scala 2.11, в котором есть метод, основанный на именах полей...

Учитывая список списков Scala: List(List(Some(1),Some(2),Some(3),Some(4)),List(Some(1),Some(2)...

Я хотел бы сделать счетчик кликов в Scala Swing . Я использовал для этого интерфейса ActionListener

Я создал простую программу, которая использует Hammock (https://github.com/pepegar/hammock), и...

Я пытаюсь суммировать все оценки на основе studentId. Я использовал lowerByKey. Но это бросает...

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

Мне нужно создать функцию, которая возвращает List [List [Option [Double]]], где функция принимает...

Я составил список для хранения некоторых последовательностей данных, где каждая последовательность...

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

Я пытаюсь создать набор данных Spark, а затем использую mapPartitions, пытаюсь получить доступ к...

Я использую Neo4j разъем для Apache Spark . При запуске кода с помощью spark-shell он работает в...

Когда новый поток создается с использованием черты scala.concurrent.Future, имя нового потока...

def rankLangs(langs: List[String], rdd: RDD[WikipediaArticle]): List[(String, Int)] = langs.map(lang...

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

Я пытаюсь случайным образом заполнить массив, но программа возвращает Select (0.3 -> 3, 0.4 -> 4, 0