У меня есть механизм обмена сообщениями Akka, который доставляет миллионы сообщений в течение дня,...

У меня есть черта «Значение» и расширяющий класс «Уравнение», например: trait Value { def apply(in:...

Я устанавливаю кэш с областью запросов http для фьючерсов scala.В рамках одного запроса есть...

Я пытаюсь выполнить блокировку UPDLOCK для строки таблицы БД, используя scala slick, а затем...

У меня есть искровая работа, написанная на scala с junit. Когда я запускаю эту работу с помощью...

скажем, у одного есть несколько файлов в каталоге, каждый из которых File1 20100101|12.34|......

У меня есть это: Set[ValidatedNel[String, Double]] , и я хотел бы сложить в нем двойные числа,...

Есть ли способ, который я мог бы использовать, если я хочу знать, как Transformer меняет схему;без...

Я новичок и в искре, и в скале.Я пытаюсь загрузить CSV-файл в базу данных Mongo, используя искровое...

Я пытаюсь отправить искровое задание в кластер hadoop-yarn через Apache Livy. Кластер настроен с...

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

У меня есть таблица в postgres, где один из столбцов имеет имя с двойной кавычкой (имя в формате,...

когда я пишу пустой фрейм данных с параметрами ("header", "true"), но он не записывает заголовок в...

Я хочу удалить строки из таблицы n-to-n с помощью подзапроса и сопоставить два столбца...

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

Для оператора Spark SQL FROM можно указать путь и формат файла. но заголовок игнорируется при...

Я довольно новичок в Scala и буду признателен за любые советы экспертов.Мне нужно проверить...

Здесь, после того как Геймер и Дилер забрали все свои карты (в игре в блэкджек), мне нужно решить,...

Допустим, у меня есть следующий фрейм данных: val df = spark.sparkContext.parallelize(Seq(...

У меня есть следующие шаги: trait BlackjackSteps { def gamerTakesTwoCards(gamerName:String):...

Как читать из нескольких тем, используя spark readStream() с разными схемами, и writeStream() в...

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

При попытке создать смешанный проект Java / Scala (пользовательский процессор NiFi, используя...

У меня есть СДР, и мне нужно применить вычисления к каждому разделу (используя .mapPartition), но...

Мне нужно сопоставить список столбцов с другим столбцом в наборе данных Spark: подумайте как-то так...