Я использую Intellij Идея для применения искры в Scala.Я не уверен, почему я получаю ниже ошибка....

Добрый день всем.Я попытаюсь объяснить мою проблему, чтобы вы могли понять меня. В нескольких...

У меня есть несколько сложных сложных файлов CSV в hdfs, каждый файл имеет одинаковую структуру, в...

В режиме искровой пряжи я объявил переменную SparkSession в объекте scala следующим образом:...

Мой код ниже выдает ошибки row.key и row.value при чтении формата AVRO от производителя при...

Я новичок в Scala и Slick.Я пытаюсь выполнить запрос с группировкой по объекту и создать две...

Я хочу иметь возможность передавать XML-файл в программу и читать его с XMLEventReader.Единственный...

Я хочу протестировать функцию, которая записывает вывод в RDD в Scala Spark. Часть этого теста -...

Я пытаюсь извлечь элементы из записей XML, где каждый файл XML имеет много записей XML.Ниже...

У меня есть один стол улья.Я хочу создать динамические запросы SQL искры. Во время отправки искры я...

Я пытаюсь построить строку путем объединения значений из фрейма данных.Например: val df = Seq(...

У меня есть запрос, подобный следующему val query = "select 'a' as col_1, '...

Есть ли простой способ проверить кодировку 1-hot bus в Chisel? Мое текущее решение кажется немного...

Я пытаюсь загрузить CSV-файл, используя Scala и Apache Spark, но, как только я задаю схему с...

У меня есть последовательность шаблонов, и я хочу сопоставить строки с этими шаблонами и вернуть...

У меня есть RDD[Sale] и хотелось оставить только последние продажи.Итак, я создал пару RDD, а затем...

PooledByteBufAllocator.metric () Lio / netty / buffer / PooledByteBufAllocatorMetric; Zeppelin...

У меня есть датафрейм (df), который выглядит следующим образом col1 col2 col3 a 20 0 a 21 1 a 22 0...

Можно ли использовать Spark API для чтения большого CSV-файла, содержащего несколько разделов с...

Я выполняю scd type2 in spark, используя две таблицы кустов (один этап с 616 миллионами данных и...

У меня есть следующий код.df3 создается с использованием следующего кода. Я хочу получить...

У меня есть несколько файлов из источника, где каждый файл содержит отдельные записи в формате

Я пытаюсь сравнить ZonedDateTime со следующим кодом: val now = ZonedDateTime.now() val query = for...

Я новичок в мире Spark и Scala. Это мой пример входных данных: val x= Seq( (1116685002,...

Я следую Страница учебного пособия по быстрому старту Spark Я достиг последней точки, скомпилировал...