Я хочу создать плагин sbt это мой проект build.sbt file: lazy val root = (project in file("
Я использую искру. Я хочу сохранить значение 2.484, которое повторяется 13849 раз в файле паркета...
Настройка Intellij Maven Project, проверенная и протестированная в Linux и Windows, работает...
Я попытался протестировать свой код, как показано в документации к игре, используя...
Я пытаюсь передать имя функции Spark SQL моей определенной функции в Scala. Я пытаюсь получить...
Я новичок в Kafka и пытаюсь реализовать потребительскую логику Kafka в spark2, и когда я запускаю...
Пытаюсь ли я создать свой собственный тестовый класс или запустить существующий тестовый класс...
Из следующего кода: type Structure = Map[String, Any] def getStructureSourceNames(structuresDesc:...
Я выполняю искорное задание, когда задачи не связаны только с процессором. Поэтому я хочу, чтобы...
Я попытался сделать скрипт для ввода данных из MongoDB в корзину S3: val mongoDF = spark.read
Как изменить порядок полей во вложенном фрейме данных в Scala? Например, ниже приведены ожидаемые и...
Я хочу обернуть свои ошибки в скаляр EitherT. Я написал этот тип, чтобы я мог все там обернуть и...
У меня есть метод, который был смоделирован и принимает Seq в качестве параметра. Я хочу проверить,...
Я пытаюсь загрузить некоторые данные из фрейма данных в azure cosmosDB. Я скачал следующие файлы...
В настоящее время у меня есть проблема, когда я пытаюсь перегрузить метод, содержащийся в quill,...
Существует 2 local метода, определенного как: final case class Kleisli[F[_], A, B](run: A =>...
Я работаю над набором данных Yelp, используя Spark Dataframe. У меня проблемы с использованием...
Я создал искровой проект со Scala. Это проект maven со всеми зависимостями, настроенными в POM....
Я использую flink-1.4.2 со scala, а RocksDB используется для бэкэнда состояния, но я не получаю...
У меня есть некоторый код scala class A (a: Int, b:Int) (implicit typeinfo: TypeInformation[T]) { .
Есть ли способ использовать Broadcast Join в FLINK так же, как я использовал в SPARK. Я работаю с...
Цель У меня есть изменяемая карта [Long, Long] с миллионами записей. Мне нужно сделать много...
class Parent class Child extends Parent val p = new Parent val c = new Child p.isInstanceOf[Parent]...
У меня есть вывод DataFrame из Scala, поступающий в Either. Я пытаюсь извлечь из него Spark...
Кажется, что новый sbt не запускается при использовании через прокси: [...][error] (*:update)...