Когда я запускал spark-shell следующей командой bin / spark-shell --packages org.apache.bahir:...

У меня есть информация в форме (очевидно, фальшивая, но служит цели): | User | Country |...

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

Из простого JavaScript мы можем тестировать функции напрямую; увидеть: Надежно определяет,...

Я новичок в Scala, перешел с Java, и у меня возникли проблемы с элегантным возвратом Map из этой...

Ошибка: <console>:195: error: not found: type Column val aggExprs: Seq[Column] = output

Допустим, у меня есть case class CC(a: Int, b: String, c: Double). Для простоты я ограничу это...

Я пытаюсь запросить данные у Solr через Spark. У меня проблема с подключением ZooKeeper. Я начал...

В настоящее время я работаю над проектом по созданию общего конвейера в Scala (исключительно для...

Этот вопрос решает случай за секунды: Как преобразовать строку даты и времени в длинную (время...

Как вы агрегируете динамически в Scala Spark на основе типов данных? Например: SELECT ID, SUM(when...

Этот метод заменяет typsafe включающие пути к файлам в файле, размещенном в каталоге ресурсов. Он...

Предположим, у меня есть раздел, который выглядит следующим образом part1:...

Я новичок в Скале.Так может кто-нибудь помочь мне с вопросом ниже: import org.apache.spark.sql

Я читаю сообщения от Кафки в оболочку Flink Scala. Я хочу прочитать несколько сообщений, сохранить...

Я создаю API, который требует преобразования регулярного выражения SQL в регулярное выражение Java

У меня есть массив буферов пользовательского объекта Employee, который имеет empname, empno,...

Я пишу один раздел через какой-то внешний процесс в таблицу. Теперь я хочу, чтобы какой-то API...

У меня есть следующий класс дел: case class Person(name: String, lastname: Option[String] = None,...

У меня есть два набора данных (фреймы данных) idPeersDS - у которого есть столбец идентификаторов и...

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

Я получаю ошибку: значение обновления не является членом scala.collection.immutable.Map [Nothing,...

Мой df похож на id col1 col2, и я хочу сложить col1 и col2 вместе, чтобы получить cols. Затем...

Я новичок в Scala, перешел с Java, и у меня возникли проблемы с элегантным возвратом Map из этой...

Структура создаваемой схемы: |-- col1: boolean (nullable = true) |-- col2: array (nullable = true)...