У меня есть датафрейм countriesDF со схемой root |-- _id: struct (nullable = true) | |-- $oid:...
Версия Logback classic 1.2.3 работает, но если я использую logback 1.3.0 alpha, который использует...
Можно ли частично определить параметризованный неявный класс? Например, предположим, у меня есть...
Вот что я пытаюсь сделать: Я читаю данные в scala Извлекаю несколько столбцов Используя JEP,...
Предположим, у нас есть 3 метода, которые все возвращают Option import scala.util.Try def...
Я пишу веб-API HTTP Akka, который подключается к экземпляру базы данных Oracle с помощью OJDCB....
У меня есть датафрейм. Мне нужно вычислить максимальную длину значения String в столбце и вывести...
У меня есть фрейм данных df_one, df_two, как показано ниже: df_one.show() -------------...
У меня есть датафрейм, полученный после чтения таблицы, как показано ниже, с использованием spark:...
Я пытаюсь начать работу с Scio, и я использовал их стартовый проект giter8. https://github
У меня есть mutable.MutableList [emp] со следующей структурой. case class emp(name: String...
Я пытаюсь написать сессионизирующий udaf для использования внутри спарк-окна. Я знаком с созданием...
Я установил спарк с sbt в зависимости проекта.Затем я хочу изменить переменные искрового окружения,...
У меня есть фрейм данных, в котором я разделил его на «matchedDF» и «unmatchedDF» на основе...
Я написал процессор макросов для аннотаций, который генерирует все те же методы, которые вы...
Я работаю с куском кода, который имеет широкую / глубокую иерархию классов дел. Для модульного...
Я использую этот запрос в SQL, чтобы узнать, сколько user_id имеют более одного электронного письма
Я все еще новичок в scala, у меня есть требование извлечь первый раздел из каждой таблицы в улье. Я...
Я использовал потоковую обработку Spark 2.1 для обработки данных о событиях от Kafka. После...
Я конвертирую ниже функции pyspark в Spark-Scala. В функции pyspark мы передаем в качестве...
Я пытаюсь настроить автономный спарк-кластер на моей машине с Windows и запустить приложение scala...
Предположим, у меня есть такой фрейм данных val customer = Seq( ("C1", "Jackie...
Ожидается, что следующий порядок инициализации без ленивого val выдает исключение нулевого...
Я использую библиотеку Netflix / Archaius для управления конфигурацией работы scala / spark. в...
Я пытаюсь использовать коннектор Hortonworks hbase для spark 2.0 для работы с hbase (https://github