Давайте предположим, что у нас есть опция foo1 и опция foo2: val foo1: Option[Foo] val foo2:...
Я хотел бы использовать jlink для создания автономных пакетов приложений для всех платформ (darwin,...
Вот код, который у меня есть: sealed trait Section { val value:String type Out } case object...
У меня есть DataFrame в spark, который выглядит следующим образом: id | flag ---------- 0 | true 1...
У меня есть итеративная функция, которая генерирует некоторые данные, которые я хочу выводить в СДР
У меня возникла проблема с длинной, сложной искровой работой, которая содержит udf. Проблема, с...
Я хочу суммировать массив столбцов в строке на основе условия.Я нашел способ сделать это, но это не...
Я создаю API для отправки мне файлов, и я буду загружать их на S3, и я использую библиотеку...
Я пытаюсь отфильтровать столбец данных, прочитанный из Oracle, как показано ниже import org.apache
Я использовал упомянутый код здесь для создания HashMap в Scala. Ниже для удобства вставьте копию:...
В моем Spark ML Pipeline (Spark 2.3.0) я использую RegexTokenizer следующим образом: val...
Недавно я столкнулся со странным явлением: var timePosSortedMap = TreeMap.empty[String, String] var...
Как написать метод с именем calculator, который принимает три строковых параметра: def...
У меня ниже 2 примеров SQL-запросов в SQL: a) update DBTABLE1 set col1 = 'Yes' where ID...
У меня есть фрейм данных со столбцом text, в котором много строк, состоящих из английских...
Я хочу посчитать количество пропущенных значений в каждой строке фрейма данных в режиме искры scala...
У меня есть SQL-код, который отлично работает: val sql =""" select a.*, b.fOOS, b
У меня есть случай, когда мне нужно загрузить миллионы данных в формате json в таблицы Apache Hive
Проблема: У меня есть класс дел Passenger, который начинается с точки A и переходит в точку B....
Я пытаюсь сгенерировать статистику клиента, используя следующий код. Это преобразование combiByKey....
Следующий код выдает UnsupportedOperationException в Scala 2.12.7 и Java 11.0.1. listBuffer
По какой-то причине, когда я выполняю код .wriestream.format (json) .option (Path). У меня есть...
У меня есть искровое задание, которое будет периодически отправляться для выполнения какой-либо...
Я не хочу читать из кеш-памяти с помощью команды sql. Поскольку команды sql являются динамическими...
У меня есть три класса дел, как показано ниже: case class Result( result: Seq[Signal], hop: Int)...