У меня есть текстовый файл, который содержит строку типа игроков = {"Месси": {"Подробности":...
Неоднозначная ошибка Spark 2.3.2, Scala 2.11.8 Это действительно проблема с двигателем Scala или...
В приложении есть следующие типы: case class Widget( id: Int, name: String, latlon: Option[Latlon],...
Может ли оператор SQL DDL быть проанализирован в простой файл схемы JSON, как показано ниже, без...
Добрый день, Я пытаюсь запустить пример scala для spark, предоставленный по следующей ссылке:...
Я хотел бы решить проблему, Я сделал этот код, и у меня есть этот вывод found : Unit [error]...
Я хотел бы найти разницу между столбцом Date в наборе данных spark и значением даты, которое не...
Я реализую код для динамического добавления нескольких столбцов в Dataframe с нулевыми значениями в...
Я пишу библиотеку в Scala для локальной обработки данных.Я хотел бы включить некоторые из функций,...
Ниже приведены данные в файле PREFIX|Description|Destination|Num_Type 1|C1|IDD|NA 7|C2|IDDD|NA...
Для этого кода: var p = result.select("finalFeatures").head.toSeq.toArray Результаты...
Работа в ноутбуке Anaconda Jupyter, в ядре Apache Toree - Scala. Я звоню: System
df.na.fill и df.na.replace не работают, если имя столбца имеет символ .. val df = List((1...
например, у меня есть массив Array[Int] = Array(1, 1, 2, 2, 3) массив б Array[Int] = Array(2, 3, 4,...
Раньше было 22, я слышал, кто-то сказал, что сейчас 512?Это верно?Может кто-нибудь предоставить...
У меня безумное количество столбцов пути, которые мне нужно разделить на 2 столбца: базовое имя и...
Я попытался реализовать пример макроаннотаций Scala, как описано в документации .Мне удалось...
У меня есть dataFrame unionDataDF с образцами данных +---+------------------+----+ | id| data| key|...
Я хочу выполнить модульный тестовый код, который читает DataFrame из RDBMS, используя sparkSession
У меня полная путаница в процессе искрового исполнения.Я ссылался на майские статьи и учебные...
Этот код должен скомпилироваться в Scala: trait Pipe { type Input type Output def apply(input:...
У меня есть перечисление Enumeratum, и мне нужно загрузить его во фрейм данных искры.Очевидно, что...
У меня есть эта программа, которая использует Apache Spark для вычисления частоты слов. Я создаю...
Как я могу объединить массив в фрейм данных, содержащий колонны [a, b, c, d, e] root |-- arry:...
Когда я бегу spark-shell в оболочке Linux, попробуйте: spark.sql("show databases").show()...