Я использую spark2.3, я получаю ошибку ниже.Я нашел этот тип многих исключений в Интернете, но не...
Мне дают строку в следующем формате: Lorem ipsum dolor <a>Hello <b>Nested</b>...
У меня есть искровой фрейм данных, к которому я хочу применить агрегатные функции, используя...
Я новичок в Scala и пытаюсь прочитать неориентированный график как Graph (GraphX) из текстового...
Ниже приведена функция быстрой сортировки, написанная на Scala для сортировки списка смешанных...
Я пытаюсь запустить программу scala lexer / parser из терминала, но она не удалась. Пожалуйста...
Мой фрейм данных выглядит так: +-------------------+-------------+ | Nationality| continent|...
Все, я новичок в Spark (программирование, если честно), и мне нужна помощь с приведенным ниже...
У меня есть потребитель kafka, который выглядит следующим образом: import akka.actor.ActorSystem...
При попытке получить имя класса с помощью ссылки WeakTypeTag при определении реализации макроса, я...
Пока я отправляю эту команду в cmd для моего рабочего стола ` spark-submit --class retail_db
Я установил kafka локально (на данный момент нет реестра кластера / схемы) и пытаюсь создать тему...
Рассмотрим следующее предназначено sql: select row_number() over (partition by Origin order by...
В моем коде scala у меня есть экземпляр Class[_ <: AnyVal], например, полученный из classOf[Int]
Я знакомлюсь со Spark и Scala, и моя текущая задача - «сложить» эти два кадра данных:...
Я добавляю столбец в фрейме данных spark, используя некоторую бизнес-логику, которая возвращает...
Код ниже написан на scala, val Array(f, t) = readLine().trim().split(" +").map(_.toInt) Я...
У меня есть CSV-файл, в котором есть столбцы, и для целей тестирования я помещаю его вручную в...
Рассмотрим общий вызов writeStream - с типичным «консольным» форматом вывода: out.writeStream
Я только начинаю с scala. Я пытаюсь научиться этому, решая простые проблемы с помощью leetcode. Вот...
Я пытаюсь проверить код набора данных (набора данных) со строго типизированными вложенными классами...
Я вроде как новичок в scala, и я придумал этот код, когда пытался узнать синтаксис совпадений,...
Я пытаюсь написать следующее: val value: Int = 3 val tpe = typeOf(value) // This is pseudocode....
Я создаю файлы orc, используя следующие import org.apache.hadoop.io.Text; import org.apache.hadoop
Я пытаюсь использовать PowerMockito в Scala для обхода вызова scala.io.Source.fromURL, который...