У меня есть простой интерфейс репозитория с операциями CRUD (возможно, плохая идея передавать...

Должны ли автоматически исключаться выселенные зависимости?В конце концов, их выселяют ... В...

// Reads Json file val input_file = ("\\path\\to\\MyNew.json"); val json_content = scala

У меня есть один CSV-файл в папке, который постоянно обновляется.Мне нужно взять входные данные из...

Я использую Spark JDBC для ввода данных в таблицу Mysql.Это также создает таблицу, если таблица не...

Я пытаюсь создать приложение Spark для выполнения агрегации на иерархическом наборе данных. Пример...

Я пытаюсь использовать метод post для входа в систему, следующий код: log(data){ let vals = JSON

У меня есть два файла паркета, один содержит целое поле myField, а другой содержит двойное поле...

Я создаю библиотеку, чтобы помочь исправить CSV, чтобы сделать это, я использую библиотеку...

У нас есть потоковые данные (DataStream [String]), как показано ниже key1 = value1 $$ key2 = value2...

новичок в apache spark здесь!Я использую Spark 2.4.0 и Scala версии 2.11.12, и я пытаюсь запустить...

Я пытаюсь создать шаблон проектирования с trait или class: class Collection(input: F[A]) { def...

У меня есть Spark Dataframe с необязательным полем X. Если поле вообще не существует, я хочу...

<row id='185685445477437.020001' xml:space='preserve'>...

Я новичок в Spark / Scala.Мой начальный RDD имеет тип Records, и расположение записей: a_key, b_key...

Я пытаюсь импортировать зависимость в моем файле build.sbt отсюда https://github

Привет всем! У меня проблема с моим кодом scala и spark.Я пытаюсь реализовать модель логистической...

Есть ли какой-нибудь возможный способ сгладить массив в Scala DF? Как я знаю, с помощью столбцов и...

Я пытаюсь прочитать CSV-файл из облачного хранилища Google в Flink REPL.Поскольку я не очень опытен...

Есть ли способ получить вывод Dataset#show() как String? Следующее выводит его на stdout, но мне...

val persons = Person () Person.mergeFrom (новый FileInputStream ("path_of_file")) Person - это...

На прошлой неделе мои интеграционные тесты работали нормально.Сегодня это исключение постоянно...

У меня есть текстовый файл в следующем формате (id,f1,f2,f3,...,fn): 12345,0,0,1,2,...,3 23456,0,0...

Я не могу обновить значение в семействе столбцов hbase.Условие - Если переменная cricketScore не...

У меня есть dataFrame, как показано ниже ----------------------------- | A | B | C |...