Я хочу читать и писать, используя структурированную потоковую передачу в Confluent Cloud. Проблема...

Я пытаюсь найти определение класса DataFrame в исходном коде scala, а не в pyspark. Есть некоторые...

У меня есть 3 фрейма данных 'u', 'join5' и site. Вот схема данных фрейма 'u'. scala> println(u

Я пытаюсь определить многопроектную сборку с последовательным числом подпроектов: . ├── build.sbt...

Я пытаюсь удалить заголовок из указанного входного файла. Но я не смог этого сделать. Че то я и...

У меня есть датафрейм с одним из столбцов в качестве эпохи. Я хочу извлечь из него только час и...

вот пример о countWords. (Scala) [origin] def countWords(text: String): mutable.Map[String, Int] =...

Я использую kafkaUtils.createDirectStream () в потоковой передаче искры. Этот метод поможет мне...

Я сопоставил класс Scala с Hibernate. Класс содержит отложенное значение, поэтому Scala...

Я пытаюсь реализовать поток Kafka, который обрабатывает сообщения о посещении веб-сайта...

У меня есть некоторые данные о рейсе / пассажире, и я пытаюсь найти максимальное количество стран,...

Хотите знать, почему этот код не работает, я что-то упустил? def treemin(lst: List[Any]): Int = {...

Я изучаю Scala и FP, и в книге «Функциональное программирование в Scala» термин Комбинатор...

Я пытаюсь получить лучшие n записей из приведенного ниже набора результатов. Но я не мог получить...

Я хотел подключить AWS Athena как Hive от Scala Spark. Может, кто-нибудь предоставит мне пример...

Я пытаюсь подключиться к HBase из приложения Scala в среде Play, я скачал проект из . Но во время...

Я пытаюсь создать фидер, основанный на данных jdbc, которые создаются на этапе перед сценарием. Мне...

У меня есть два потока Kafka: чтение с использованием API источника таблицы во Flink с...

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

Я хочу получить имя класса, переданного в качестве параметра в функцию с использованием...

У меня есть этот простой маршрут, определенный с помощью http4s : def routes: HttpRoutes[UserTask]...

Пример val str = "100" val new_$str = "200" Я должен иметь возможность получить...

Я новичок в Scala и изучаю Spark со Scala. Проблема -> У меня есть простой файл JSON, имеющий 20...

val wordList = List("I", "want", "to", "learn",...

Мне нужен кодировщик, который работает с моей функцией карты, которая берет строку и возвращает...