Я написал метод на Java, который хочу переписать в Scala.(Sales.Metrics - это Enum) for (int i = 0;...

Мой вопрос касается scala.xml и преобразования из типа Node в String (используя любые методы...

Мне нужно добавить пример Json в тело запроса на моей панели инструментов Swagger, чтобы...

У меня есть кадр данных, как показано ниже A B C D foo one small 1 foo one large 2 foo one large 2...

Можно ли настроить spark (версия 2.3.1) для пропуска отсутствующих файлов s3.Прямо сейчас он выдает...

У меня класс с огромной нагрузкой на обработку, и для этого я использую очередь блокировки для...

Я хочу объединить две tables A and B и выбрать для каждого значения записи с максимальной датой из...

Я знаю, что можно удалять или пропускать файлы и папки при выполнении maven clean . Моя проблема...

Как найти зарплату в пределах диапазона?Вот мой код данных Spark SQL для определения зарплаты между...

Мы работаем над написанием существующей утилиты Python в Scala.Утилита загружает сжатые данные из...

У меня есть следующий Dataframe: val df = Seq( ("a",Some(1.0)), ("b",None),...

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

Попытка установить Spark и связанные программы на Mac, но получение сообщений об ошибках при...

Я делаю сторонний вызов API, используя Play WS, чтобы вернуть объект JSON со списком объектов.Я...

Я работаю на языке программирования Scala и пытаюсь сгенерировать json из case class. Я следую...

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

Предположим, есть черта с абстрактными методами, имеющими разные сигнатуры (см. Ниже).Чтобы...

Короче говоря, я разработчик, пытающийся использовать Spark для перемещения данных из одной системы...

Я использую Apache Spark 2.3.0.Когда я загружаю файл CSV, а затем помещаю файл df.show, он...

У меня есть два df's df1 ID | BTH_DT | CDC_FLAG | CDC_TS | CNSM_ID 123 | 1986-10-07 | I |...

Я написал следующее регулярное выражение: val reg = ".+([A-Z_].+)

В оболочке Spark я пытаюсь создать столбец Set-valueed, но Spark интерпретирует его как массив....

Как преобразовать объект набора данных в фрейм данных?В моем примере я конвертирую файл JSON в...

Это элегантный способ сопоставления с образцом в коллекции scala Iterable[A], чтобы проверить,...

Я хочу создать новый столбец end_date для id со значением start_date столбца обновленной записи для...