Я написал следующий код, целью которого является преобразование кадра данных в набор данных с...
После выполнения некоторой операции я получил rdd (например, следующий) массива (любого), где все...
Я хочу конвертировать массив [String] в файл JSON. Это выглядит так: scala> ok.foreach(println)...
Мне нужно создать один фрейм данных для каждой строки фрейма данных. Следующий код создаст один CSV...
Я делаю приложение scala-spark, которое получает данные из MySQL.Если я бегу от затмения, это...
Я пытаюсь преобразовать все столбцы моего информационного кадра в отдельные массивы. Поддерживается...
Я создал класс и использовал этот класс для создания СДР. Я хочу вычислить сумму LoudnessRate (член...
Я пытаюсь создать фрейм данных из 10 тыс. Записей, чтобы затем сохранить его в файл паркета на...
У меня есть два Seqs, которые я хочу использовать для добавления столбцов в фрейм данных. Seq one -...
Представьте, что у вас есть строка, содержащая символ амперсанда, и моя цель - добавить пробелы...
Я бы хотел найти минимум года и месяца и максимум года и месяца из фрейма искры.Ниже мой фрейм...
Я пытаюсь прочитать файл avro с Source из akka Streams. Источник в потоках akka читает данные,...
Я хочу сгруппировать свой набор данных по этой первой части моей строки.Таким образом, чтобы...
У меня есть CSV-файл: Name;Date A;2018-01-01 10:15:25.123456 B;2018-12-31 10:15:25.123456 Я пытаюсь...
Я создаю приложение spark, которое зависит от библиотеки Java. Интерфейс Java представлен как...
У меня есть следующий код: def main(args: Array[String]) { var dvfFiles : String =...
У меня есть два набора данных (dsFile и dsTable) со следующей схемой: dsFile: dsFile |-- A: string...
Я немного новичок в scala spark. Я не мог найти ответ по этому поводу. У меня есть такие массивы...
Мне нужно преобразовать строку (дата с часовым поясом) в метку времени.Преобразованный столбец...
Краткий вопрос : Для более прямого запроса я хочу последовательно выполнить все строки и назначить...
Я пытаюсь обновить документ ES по этой ссылке https://www.elastic
Я могу создать RDD, если у меня есть список и выполнять необходимые операции, как val li = List(1,...
После обновления play Framework с версии 2.3 до 2.4 сборка завершилась без ошибок, но после доступа...
У меня есть кэш воспламенения, в который постоянно вставляются данные.Есть ли способ получения...
У меня есть следующий фрейм данных: df.show()...