Мне нужно проверить условие, если ReasonCode равен "YES", а затем использовать ProcessDate в...

Разработано: хотите реализовать scala-код с использованием структурированной потоковой обработки...

как я могу использовать функциональную парадигму программирования для удаления 'var' в следующем...

У меня есть dataframe - преобразованные dtypes в карту. val dfTypesMap:Map[String,String]] = df

Возникли проблемы с воспроизведением и фильтрами Http, я использовал несколько методов, чтобы...

У меня есть List [String] и я добавляю значение этих строк в качестве имен столбцов в существующий...

Во время использования Akka HttpRequest и передачи запроса актеру, я не смог определить ответ.Актер...

Можно ли выполнить собственную логику при группировке набора данных Spark?Вот пример простой печати...

Я работаю над приложением Spark, которое передает данные из двух разных тем topic_a и topic_b...

// package com.jsonReader import play.api.libs.json._ import play.api.libs.json._ import play.api

Я пытаюсь понять, как использовать эффектные монады (cats.effect.IO или scalaz.IO не имеет...

Ниже приведен фрагмент кода: package caseClassExp sealed trait Resources { def fullpath :String }...

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

Давайте рассмотрим следующую черту: sealed trait AB case class A(a: Int) extends AB case class B(b:...

У меня два спарк-фрейма данных 100 dfA и dfB.Я хочу фильтровать dfA по dfB каждой строке, что...

Предположим, что замыкание было выполнено в JVM и создает объект в области действия этого замыкания

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

Я хочу "перевести" список чисел ( диапазон -999, 999 ) в список строк в Scala: Функция: def...

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

Я пытаюсь функционально написать тело для этой функции: grouping[T](xs: List[T], rule: T =>...

Я написал код для извлечения записей из кафки в спарк.Я столкнулся с каким-то странным поведением

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

Согласованность типов классов является общеизвестной проблемой. Например, Monad должно быть Functor...

Как запустить программный автономный мастер Spark в Scala? В связи с этим документом: https://spark

Консольные команды kafka-console-producer.sh и kafka-console-consumer.sh работают правильно, но...