мы работаем над проектом Maven, в котором есть тестовый код, написанный на Scala.Теперь существует...

var clearedLine = "" var dict = collection.mutable.Map[String, String]() val rdd =...

Мне нужно загрузить файл со стороны клиента и манипулировать им на стороне сервера.После...

Вот как я вычисляю гистограмму по одному столбцу: val df = spark.read.format("csv")

Я запускаю программу для Spark потоковой передачи с использованием Kafka и получаю ошибку.Весь...

Привет, я застрял в реализации пользовательского условия по искровому DF.По сути, я хочу пометить...

из любопытства, мне было интересно, можно ли было сделать что-то вроде: def myMethod( a: Option[A]...

Я изучаю создание настраиваемой логической схемы Spark SQL CSV для определения пользовательских...

Я пытаюсь вставить данные раздела из одной таблицы (текстовый формат) в другую таблицу (формат...

У меня есть хэш-карта, в которой я сохранил значения Map(862304021470656 -> List(0.0, 0.0, 0.0,...

Я получаю эту ошибку в Kafka 2.0, в то время как код работает для Kafka 1.1 "Exception in...

Я не могу определить ZipWith out как In другого ZipWith.Он получает только одно событие от одного...

Я пытаюсь сопоставить два кадра данных на основе окна переменной даты.Я не просто пытаюсь получить...

Я пытаюсь проанализировать какой-то проблемный Json в Scala, используя Play Json и используя...

Я не могу найти решение для сообщения об ошибке, которое я получаю при запуске spark-submit в...

Я начал читать о дженериках скалы.Кто может объяснить мне, почему работает этот код? sealed...

Когда я выполняю функции groupby и pivot с помощью Spark (набор данных), исполнители не работают....

Я программирую на scala, когда я пишу простую программу "println (" hello world ")" и использую...

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

У меня есть несколько потоков в Spark 1.6, записывающих в одну и ту же таблицу кустов (с...

Здравствуйте, я новичок в фреймворке.В build.sbt я попытался добавить искровую потоковую...

Один из столбцов в моем входном наборе данных имеет значения, подобные приведенным ниже: "Super...

def example1(sss:Seq[Seq[String]]) = sss match { case Seq(a, b) :+ Seq(c, d) :+ tail => true }...

У меня есть 2 файла, как показано ниже. Файл ключевых слов spark scala hive Файл содержимого this...

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