Вопрос немного сложно сформулировать, поэтому я попытаюсь привести пример: def myThing(): (String,...

Я пытаюсь использовать рефлексию для вызова моего java-метода из класса scala. Я ссылался на этот...

Я новичок в Spark и Scala, поэтому понятия не имею, как называется проблема такого типа (что делает...

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

У меня есть фрейм данных c1 c2 user1 5 user2 3 user3 3 user4 1 Я хочу разделить фреймы данных на 3...

Мне известно о spark.sparkContext.statusTracker но я могу иметь доступ только к номеру Executors и...

У меня есть Rdd[(Int, Double)] и array[Int], и я хочу получить новый Rdd[(Int, Double)] только с...

У меня был код, который использовал сборку ExecutionContext (EC) с akka (ActorSystem). Этот код...

У меня есть потоковое задание Spark, которое объединяет строки, используя идентификатор и временное...

Может кто-нибудь объяснить мне, почему RDDFunctions.sliding должен возвращать пустой RDD, если...

У меня локально настроен спарк 2.2, и я работаю со scala Конфигурация сеанса спарка ниже val...

У меня есть класс, похожий на Pairs. У меня есть черта, которая преобразует этот класс Pairs в...

У меня есть набор данных, загруженный из файла .csv (здесь имитируется ds), который содержит 2...

Я хочу загрузить открытый ключ PEM для шифрования значения. В Python я бы просто использовал...

Я новый сотрудник Scala и использую библиотеку обработки в Scala, у меня есть 2 вопроса здесь: val...

Я работаю над реализацией потокового приложения Spark, и мне нужно удалить дубликаты строк на...

Я поместил инструкции log.info внутри своей UDF, но в кластере происходит сбой.Местные работают...

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

Я хочу, чтобы моя служба только для подписчиков Lagom подписывалась на тему Kafka и передавала...

У меня проблемы с типами, зависящими от пути. У меня есть несколько типов Foo с абстрактным членом...

Я пытаюсь подписаться на тему в kafka, используя оболочку scala, и ниже приведена команда, которую...

У меня есть программа, которая берет данные из вложенных каталогов и затем обрабатывает их.Я думал,...

У меня есть датафрейм, который выглядит следующим образом: column1_ID column2 column3 column4 A_123...

Проблема в том, что у меня есть программа, которая собирается и работает нормально. Он написан на...

возможно ли сгенерировать 32-байтовый закрытый ключ ecdsa в Java с помощью KeyPairGenerator? Я имею...