Я ищу способ получить новый столбец во фрейме данных в Scala, который вычисляет min / max значений...
Я хочу узнать количество достижимых вершин из данной вершины в ориентированном графе (см....
Я пытаюсь представить метод Java через Scala (более подробно об оригинальном методе Java - он...
Я получаю приведенную ниже ошибку при запуске кода в Zeppelin, тогда как тот же код работает...
Я использую Kafka Producer и Spark Consumer. Я хочу передать некоторые данные в теме в виде массива...
Я хочу проверить, является ли .csv null или нет. Если не null и содержит запись, обработайте файл,...
ScalikeJDBC's ConnectionPool страница документов говорит: Заимствованные соединения Просто...
Окружающая среда Скала Apache Spark: Spark 2.2.1 EMR на AWS: emr-5.12.1 Содержание У меня есть один...
Могу ли я отобразить функции Scala на JSON; или, может быть, по-другому, чем JSON? Я знаю, что могу...
Я совершенно новичок в программировании scala и пытаюсь понять функцию, написанную (функциональное...
Scala: Как создать несколько методов и применить их один за другим? У меня есть список:...
Scala версии 2.11 и Spark 2.0.1. У меня есть датафрейм, где я делаю некоторые операции внутри udf....
Мы хотим сохранить наши модели данных в DynamoDB. Мы используем Scanamo с Alpakka для...
Как я могу получить пересечение значений в парах ключ-значение? У меня есть пары: (p, Set(n)) , в...
Я пытаюсь представить метод Java через Scala (от Kafka: https://kafka.apache.org/10/javadoc/index
Как написать регулярное выражение Scala для захвата всего цитируемого содержимого между двумя...
Моя текущая работа заключается в создании процессов ETL с SparkSQL / Scala с использованием Spark 2
Я пытаюсь протестировать свое приложение Scala Play с помощью юнит-теста, но поведение, которое я...
Я читаю кучу журналов, которые выглядят примерно так: id type amt 0 A 100 1 B 200 2 A 100 3 A 300 4...
Итак, я пытаюсь настроить log4j в своем коде scala. Это то, что я до сих пор: LogHelper.scala...
У меня есть особое требование для денормализации данных, как показано ниже: Исходный кадр данных:...
Я новичок в Spark. Я хочу вывести 2 верхних упоминания в твиттере, используя этот файл test.txt: "Я...
Я читал о Дотти, так как похоже, что она собирается стать scala 3, и заметил, что проекции типов...
Когда я запускаю этот код, в некоторых случаях я получаю пустую ошибку коллекции. val result = df
Я новичок в программировании на spark и scala, я пробовал запустить пример с spark-submit в...