После группировки моего набора данных это выглядит следующим образом (AD_PRES,1) (AD_VP,2)...
Я хочу максимально использовать неизменяемую структуру данных.Очень общим случаем в нашей кодовой...
У меня есть класс дела case class DDD(abc: String, v1: String, v2: String) , и у меня есть кортеж...
У меня есть проект maven spark java, который я хочу запустить на своем локальном компьютере, но...
SparkConf имеет метод registerKryoClasses: def registerKryoClasses(classes: Array[Class[_]]):...
Я хочу эффективно фильтровать СДР при сопоставлении его.Это возможно? Вот псевдокод для того, что я...
Я пытаюсь позвонить map на PairRDD.Spark дает мне эту подпись: map[U](f: (A,B) => U) Я ожидал...
Я следую базовому примеру коннектора spark hbase, чтобы прочитать таблицу HBase в версии 2.2.0...
У меня есть приведенные ниже сведения о типе данных из схемы таблицы улья, и мне нужно получить его...
У меня есть файл Scala, и я хочу запустить его в Scala Shell. Я использую следующую команду: load...
Я разработал приложение Spark Streaming, которое работает на 120-секундных микропакетах, по сути,...
Используя CqlSession , меня привели к нам несколько CompletionStage . Сначала я использовал...
Существует некоторая таблица: case class Thing(name: String, color: Option[String], height:...
У меня есть служебная функция, написанная на scala для чтения паркетных файлов из корзины s3. Может...
Я пытаюсь загрузить несколько CSV на спарк с помощью функции sqlContext.read. val df=sqlContext
У меня проблема, когда он дает мне ошибку "'[' expected but integer literal...
Я пытаюсь запустить gsutil в Scala, но это не сработает, если я не введу явно код .cmd в коде.Мне...
Я пытаюсь перенести проект, который был построен на jdk8, используя play и инфраструктуру Akka, на...
Я пытаюсь собрать набор данных в формате JSON val df = spark.sql("select invn_ctl_nbr,cl_id...
Я начинаю со Spark, и файл, который мне нужно проанализировать, имеет следующую форму:...
У меня есть следующие классы в Scala: class A { def doSomething() = ??? def doOtherThing() = ??? }...
Я пытаюсь внедрить UnitOfWork в свои репозитории, используя Guice in Play.Я пытаюсь настроить...
У меня есть ситуация, аналогичная описанной в этом вопросе. Но мой полный проект находится в Scala,...
В чем разница между collect_list() и array() в искре с использованием scala? Я вижу использование...
Я новичок в Scala, и я хотел бы понять некоторые базовые вещи. Прежде всего, мне нужно вычислить...