Вопросы с тегом 'scala'

Количество результатов: 15653

-4 голоса
1 ответ
Эффективный способ петли через искровой dataframe и определить, отсчеты значений столбцов как типы

У меня искры dataframe, Я хотел бы через петлю каждый столбец в dataframe и определить количество типов данных (INT, строка, логическое значение, datetype) для каждого...

0 голосов
2 ответа
Как улучшить группировку по голове

Предположим, у меня есть кусок кода: case class A(xs: Seq[Int]) def groupByHead(as: Seq[A]): Map[Int, Seq[A]] = as.filter(_.xs.nonEmpty).groupBy(_.xs.head) grou...

1 голос
2 ответа
Как преобразовать Set [String] на карте [String, String]?

Я хочу, чтобы преобразовать Set к а Map, что-то вроде: val x: Set[String] = Set("asds", "reqrq", "dadas") x.fold(Map.empty[String, String]) { (p: Map[String, Strin...

1 голос
1 ответ
Как получить результат последнего оператора SQL в Слик

У меня есть следующий код Scala: db.run(sql""" DECLARE @Ids TABLE (ID INT NOT NULL, UNIQUE CLUSTERED (ID)); INSERT INTO @Ids VALUES ...; SELECT A.* FROM SomeTab...

-3 голоса
1 ответ
Как использовать createpairedStream в MQTTUtils?

Я не могу использовать MQTTUtils.createPairedStream() в Scala? Как определить список тем как параметры? Я перепробовал все способы, как словарь, список, корте...

-7 голосов
1 ответ
Искра: как сгруппировать один столбец элементов на основе других двух столбцов элементов в РРУ

Я хав РРЫ с 3-х столбцами (road_idx, snodeidx, enodeidx). Это выглядит следующим образом: (roadidx_995, 1138, 1145) (roadidx_996, 1138, 1139) (roadidx_997, 2740, 1020...

0 голосов
1 ответ
java.lang.NoClassDefFoundError: Scala/выполнения/LazyBoolean

scala> augmentedDF1.write.format("com.mongodb.spark.sql.DefaultSource").option("database", "testdb").mode("overwrite").option("collection","e_logs").save() java...

-3 голоса
1 ответ
Как повторно использовать значение, полученное в одном объекте Scala в другую?

Я пытаюсь повторно использовать RDD что я вычислений в одном объекте в какой-то другой объект. То, что я хочу, чтобы сформировать RDD только один раз, а затем повторно...

1 голос
1 ответ
искровой SQL встроенной функции DayOfMonth возвращения странных результатов

По какой-то странной причине, dayofmonth функция искры, кажется, возвращает странное значение в течение многих лет 1500 or less. После были результаты, которые были п...

-3 голоса
1 ответ
Индекс элемента массива в Скале

У меня есть таблица со столбцом массива, как: +-Name-+ array 0: {"given_name":"B. A.", "surname":"Name1"} 1: {"given_name":"A.", "surname":"Name2"} 2: {"given_...

0 голосов
0 ответов
Как устранить общие предупреждения стирания типа?

Вот функция: def func(map: Map[Any, Any]): String = { val mapping: Map[String, String] = map.map{ case (k: Int, v: mutable.WrappedArray[String]) => k.t...

1 голос
1 ответ
Спарк Structured Streaming groupByKey на временное окно не работает

Мне нужно, чтобы партия мой Кафка поток на временные окна по 10 минут, а затем запустить некоторые пакетную обработку на нем. Примечание: записи ниже, имеют поле врем...

1 голос
1 ответ
Scala => с =

Я пытаюсь понять, Spark, внутренности, а также новые для Scala. Я хотел бы задать значение (index, res) => results(index) = res в этом заявлении в SparkContext.scal...

0 голосов
2 ответа
Что такое тайм-аут по умолчанию Спросите в Акку?

Что такое значение по умолчанию для тайм-аута Ask в Акку? Все, что необходимо использовать аск метод в Акку является импорт akka.pattern.ask. В Документах, есть приме...

0 голосов
0 ответов
Я не могу понять, третий случай в этой функции в Scala слияния

В случае (x::xs1, y::ys1) когда же x, y ys1 & xs1 создан? def mergesort[T](less: (T,T) => Boolean)(xs: List[T]): List[T] = { def merge (xs: List[T], ys: List[T])...

1 голос
0 ответов
Проверьте, что метод а SCALA Синглтон объекта звонит другой метод

У меня есть объект, который одноплодный Скала Я хочу, чтобы тест, который выглядит в основном, как это object myObj { def m1(a1: String):String = { if(a1 == "...

0 голосов
0 ответов
Как получить Maven и/или Scaladoc для испускают документации класса API тест

Я в настоящее время использую <plugin> <groupId>net.alchim31.maven</groupId> <artifactId>scala-maven-plugin</artifactId> &lt...

0 голосов
0 ответов
Как представляют Postgres TIMESTAMP БЕЗ ZONE в Jooq

У меня есть приложение Scala, используя Joda времени LIB, который подключен к Postgres БД, и я хочу использовать Jooq LIB. Я хочу, чтобы хранить свои данные с отметкой...

0 голосов
1 ответ
как проверить, если список пуст в классе EitherT лестницы

у меня есть следующий код, который запрос БД и возвращаемое значение, то значение, обернутый в классе EitherT, val result = emailModel.getStatusByEmail(emailAddress)...

1 голос
1 ответ
Не удается подключиться к PostGreSQL контейнер Docker через Play рамочным сервера

Это мое docker-compose.yml файл version: '3' services: polymer: restart: always container_name: svcss_container build: conte...

3 голоса
1 ответ
Как создать большой фрейм данных искровых случайное содержимого с помощью Scala?

Мне нужно создать большой фрейм данных с искровым 1000+ столбцами, 10М + строк, 1000 перегородками со случайными данными для тестирования. Я знаю, что нужно создать бо...

-2 голоса
1 ответ
Как добавить три байта в Scala?

Я пробовал много способов но не все еще знают, как это сделать: def to24Bits(p: Int, q: Int, r: Int): Int = { (p<<8|q<<16|r<<24) } to24Bits(0...

1 голос
0 ответов
Понимание Scala Mima Выход

Я пытаюсь использовать Мим (https://github.com/lightbend/migration-manager#usage), Чтобы определить, какие бинарные несовместимости между v1.2.0-M9 Аргонавт-бесформенн...

2 голоса
1 ответ
Как использовать бесформенный для преобразования родового Map [String, Any] в случае класса внутри родовой функции?

Я пытаюсь следовать ответ здесь https://stackoverflow.com/a/31641779/1586965 То есть, я хочу, чтобы иметь возможность конвертировать (потенциально вложенный) Map[Stri...

0 голосов
0 ответов
Как использовать scalacss виджеты из JavaScript?

У меня есть то, что я считаю завершенный стилем здесь: val ccrsEdButton: StyleA = style( backgroundColor.silver, border(1 px) , cursor.pointer, margin(5 px), ...

1 голос
3 ответа
Как получить тип подписи, чтобы согласиться с компилятором при лестницу извлечения значения из Опциона [A]?

Скажем, у меня есть переменная x то есть типа Option[Double]. Я хочу, чтобы получить, что двойной аут переменных, так что я подозреваю, что x.getOrElse(None) будет пра...

0 голосов
1 ответ
Понимание FLiNK точки сохранения и контрольно-пропускные пункты

Рассматривая Apache Flink потокового приложения с конвейера, как это: Kafka-Source -> flatMap 1 -> flatMap 2 -> flatMap 3 -> Kafka-Sink где каждый flatM...

-2 голоса
1 ответ
Как продлить двоичный с Scala?

Я пытаюсь закончить ниже упражнение: Я попытался его ниже, но мой код не действует, как ожидалось. def extend(p: Long): Long = { var e = p.toBinaryString if...

0 голосов
1 ответ
Как бросить WrappedArray [WrappedArray [(String, String)]] для массива [String] в Спарк (Scala)

Хороший, Я работаю с искровыми рамками в Scala. Мой dataframe имеет столбец со следующей структурой и содержанием: +-------------------------------------------------...

0 голосов
2 ответа
драйвер MySql не нашел для программы Scala

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

1 голос
1 ответ
Сериализация объектов Scala

Я следую основной пример сериализации объекта лестницы. Тем не менее, при выполнении теста ниже единицы package mytest import java.io.{ByteArrayOutputStream, ObjectO...

3 голоса
1 ответ
Автозаполнение случае матч в Intellij Scala

в прошлом я имел IntelliJ сделать AWSOME автозаполнения случаев, когда соответствующий любому запечатанный признака (например, Option), Но не может заставить его работ...

1 голос
2 ответа
Преобразование Scala Array [Object] для карты

У меня есть массив с объектами (Array[Organisation]). Organisation объект содержит long orgId и string orgName. Есть удобный способ преобразования этого в Map[Long, ...

0 голосов
2 ответа
Добавить новую запись перед другим в Спарк

У меня есть Dataframe: | ID | TIMESTAMP | VALUE | 1 15:00:01 3 1 17:04:02 2 Я хочу, чтобы добавить новую запись с искровым Scala раньше с тем же в...

1 голос
2 ответа
Spark: Будет ли dataframe отформатировали одному из опыта узла шаффла, когда группиЙ называются на нем?

Предположим, у меня есть некоторые данные, которые все на том же разделе (я выполнил .coalesce(1) на dataframe ранее). Теперь я хотел бы, чтобы сгруппировать данные и ...

0 голосов
1 ответ
не может прочитать файл CSV, присутствующий в AWS S3 папку локально в IntelliJ с помощью искрового Scala

I am trying to read a csv (native) file from an S3 bucket using a locally running Spark - Scala. I am able to read the file using the http protocol but I intend to use...

3 голоса
0 ответов
В Спарк, Что является причиной получения исключения EOF, Ищи в прошлом конец файла?

Я читаю некоторые данные (8 ГБ) данные из нескольких файлов, фильтровать данные делают некоторые проверки нулевых и выполнение некоторых upliftings (операции) на колон...

1 голос
1 ответ
Отображение списка в YML к списку объектов в Scala (Spring загрузки)

Фон: Я прочитал много примеров о том, как использовать ConfigurationPropertiesчитать список из конфига .. смотрите ниже Отображение списка в YAML к списку объектов ...

7 голосов
3 ответа
SBT установка несколько проектов, когда подпроекты строить файлы зависят от неуправляемых JAR-файлов

Сценарий: Я хочу, чтобы разработать проект, написанный на Scala, который зависит от проекта, также написанной в Scala. Часто бывает так, что мне нужно изменить proje...

1 голос
1 ответ
Как я могу убедиться, что я применил правильный формат код в IntelliJ

У меня есть и Java и Scale код проекта. Редактирование 2 типа кода в одной задаче является распространенным явлением. Я вводится в схему Google-ява-код стиля для форма...

7 голосов
2 ответа
Shapeless - дедуплицирующие типов в Копроизведении

Учитывая, что у меня есть тип Int :+: Int :+: String :+: CNil, Есть простой способ, чтобы превратить его в Int :+: String :+: CNil?

1 голос
1 ответ
Scala - Попробуйте преобразовать против матча против метода карты

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

0 голосов
1 ответ
Разница между :: и типы Nil в Scala

Я учусь Scala и работать со списком и создание списка строки следующим образом: val myList = List("Laptop", "Mouse", "Keyboard", "screen") Из документации, я получи...

0 голосов
0 ответов
Как создать FUNCTION1 параметром класса и возвращения класса

Я хочу зарегистрировать метод Scala объекта в искровом UDF. Теперь я получаю MethodMirror на Скале отражает и параметры с помощью Java отражения. Но я не могу сгенерир...

1 голос
0 ответов
Как запустить SPARQL с помощью Jena Elephas и искру

Я хочу сделать SPARQL на данных, которые хранятся в HDFS или данных в РДДЕ переменного с помощью Jena Elephas и искры. Я попытался ниже, чтобы прочитать файл РДФ и хр...

0 голосов
1 ответ
Как смоделировать фильтр цветения в Scala

Я пытаюсь моделировать фильтр цветения в Scala. Сама логика на самом деле довольно проста, но я изо всех сил, чтобы выяснить, как использовать структуры данных в Scala...

1 голос
1 ответ
Flink: операторы не определены в потоковом топологии. Невозможно выполнить

Я пытаюсь установить очень простой FLiNK работу. Когда я пытаюсь запустить, получить следующее сообщение об ошибке: Caused by: java.lang.IllegalStateException: No ope...

-3 голоса
1 ответ
Разбивает строку в Dataframe с помощью Scala на Спарк

У меня есть файл журнала, который имеет более 100 столбцов. Из них я только необходимы два столбца «_raw» и «_time», так что я создал погрузили логфайл как «CSV» DF. ...

0 голосов
0 ответов
Не удается связать собственные библиотеки. Javah в проекте SBT (Scala): Не удалось найти файл класса

Предположим, у меня есть приложение под названием vectorMul2, запрограммированный в Scala и скомпилирован с использованием SBT. Это приложение имеет класс Wrapper с со...

0 голосов
0 ответов
импорт путаница Scala

Я использую breeze, Общий пакет в scala, и я также создал пакет с именем breeze, В рамках которого я создал объект под названием Utils. Таким образом я могу import ...

1 2 3 4 5 6 7 8 ... 99 100 right