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

Я определил Dockerfile с установкой Spark.И я хотел бы загрузить свое приложение из сценария bash,...

Мой исходный код, но он принимает все числа независимо от длины.Мне нужно заменить только 5...

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

Я часто использую Window-функции в Apache Spark, например, для вычисления кумулятивных сумм.До сих...

У меня огромный набор данных с почти 600 столбцами, но, хотя я пытаюсь создать DF, происходит сбой...

Я пытаюсь записать Dataframe в Postgres, где имена столбцов в Dataframe являются кодами в верхнем...

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

Я просто изучаю scala и работаю над созданием кода в качестве упражнений.Я знаю, что сопоставление...

В spark я пытаюсь рассчитать три транзакции в одном окне.Поскольку у меня есть другой пример,...

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

я использую искры со scala и имею проблему с типом TimestampType object regressionLinear { case...

Я пытаюсь перейти от F # к Scala.В F # мы можем легко создать последовательность с выражением...

У меня есть Dataframe с 2 столбцами tag и value. Я хочу добавить новый столбец, содержащий столбец...

Я использую Akka Java API 2.5.12.Я хочу реализовать push sender .Я использую бесконечный цикл с...

Я хочу изменить схему существующего фрейма данных, но при изменении схемы возникает ошибка....

Я чувствую тенденцию, что большинство функциональных языков, таких как Kotlin и Scala, обрабатывают...

Ранее я использовал CatalystSqlParser для разбора входных строк в DataType следующим образом:...

У меня есть следующий код: - val conf = new SparkConf() .setAppName("Data")

Я кодирую приложение, которое генерирует отчеты из базы данных Друида.Мои интеграционные тесты...

Я занят крупной задачей по рефакторингу некоторых устаревших кодов Scala / Akka, и меня преследует...

У меня есть df, и мне нужно искать, есть ли какой-либо набор элементов из списка ключевых слов или...

Я хочу реализовать комбинированную функцию в Scala, и мой код выглядит следующим образом: def...

У меня есть данные в файле, как показано ниже: 7373743343333444. 7373743343333432. Эти данные...

Мой код написан на Spark и Scala.Теперь мне нужно измерить прошедшее время определенных функций...