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

Я пишу задание Spark в Scala, которое читает файлы паркета на S3, выполняет некоторые простые...

Я пытаюсь использовать пользовательские кодеки Circe для декодирования json в Список признаков...

Подсчет количества сумм кубов, равных целевому значению. Для небольшого количества наборов этот код...

Перебрать все представления из источника и сохранить его в виде фрейма данных в блоках данных;...

Scala List API имеет множество функциональных методов, похожих на Lodash: https://www.scala -lang

Между Scala (2.12.8) самостоятельного типа trait T { this: Any => } и это trait T { this: Any }...

Известен ли способ использования Hadoop api / spark scala для копирования файлов из одного каталога...

У меня есть программа на Java, которая постоянно проверяет запланированное задание и выполняет его....

У меня есть такой фрейм данных: ev1 ev2 Score seconds A A 9 0 B E 1 0 C C 6 8 D B 3 10 E D 5 0 A E...

У меня есть 2 потоковых запроса, как показано ниже val streamingQuery = injectableDependencies

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

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

Просто для быстрой ясности для того, кто хочет начать работать с библиотекой Scala FP, чтобы стать...

Я хочу преобразовать коды символов из UTF-8 в Shift-JIS в файле data.txt. Что мне делать? Это мой...

Как мы можем объединить перекрывающийся массив в один, используя искру. ids --------- [1,2,3] [2,3...

Я пытаюсь прочитать таблицу на postgres db, используя spark.Для этого я написал следующее: val...

Мой файл sparquet вот так идентификатор, имя, дата 1, а, 1980-09-08 2, б, 1980-09-08 3, с,...

Я хочу записать полный отправленный HTTP-запрос и полученный ответ с помощью метода Http () в...

Водяной знак позволяет учитывать данные, поступающие с опозданием, для включения в уже вычисленные...

У меня есть путь к CSV, с которого я хотел бы прочитать.Этот CSV включает в себя три столбца: «тема...

Есть ли способ сохранить сводку большого RDD в памяти, как summaryRDD, на которой большинство...

У меня проблемы с подключением к моей базе данных neo4j с помощью задания зажигания EMR. Несмотря...

Я использую Zeppelin с переводчиком в режиме «За заметку / Объем».Хотя я могу обмениваться...

У меня есть искровой фрейм данных, который я передаю как Array [Array [String]]. Мое требование...