Контекст: я работаю в одном кластере datastax dse 5.1.8 с версией spark 2.0.2.17 и версией Scala 2
В Java у меня уже есть объект scala.collection.mutable.wrappedArray. Как я могу преобразовать его в...
Я хочу заполнить (id, ArrayBuffer[ArrayBuffer[Double]]) из Dstream batch.Мои входные данные имеют...
Я использую JsValue asOpt для преобразования json в модель T. Моя проблема в том, что...
Я новичок в Скале. У меня вопрос по поводу List class. Это абстрактный и закрытый класс. Это...
У меня есть несколько файлов .nt (NTriples) в каталоге. Я хочу прочитать каждый набор данных и...
Как правильно написать метод, работающий с любым классом? у которого определена операция сложения?...
Я использую spark-2.3.0-bin-hadoop2.7 и sparkling-water-2.3.5 на 64-битной Windows 10. Я предпринял...
У меня есть RDD некоторого mutable.Map[(Int, Array[Double])], и я хотел бы уменьшить карты на Int и...
У меня есть абстрактный класс, например, так: abstract class Base { val myInners = mutable
У меня есть поток неупорядоченных measurements, которые я хотел бы сгруппировать в пакеты...
Я проектирую что-то вроде Service s и столкнулся с проблемой дизайна.Вот что у меня сейчас есть:...
Я пытаюсь запустить этот проект Github. В нем говорится, что для запуска приложения нужно запустить...
у меня есть набор данных социальной сети, содержащий информацию о том, как мне нужно найти наиболее...
У меня есть фрейм данных, который содержит строки, подобные приведенным ниже, и мне нужно разделить...
У меня есть парсер, который представлен функцией: type Parser = Array[Byte] => String Итак, у...
У меня возникли проблемы с выяснением того, как декодировать json с корневым массивом в класс case...
Можно ли выполнять несколько запросов параллельно, используя Doobie? У меня есть следующие (псевдо)...
Я использую IntelliJ для разработки проекта Scala. Из-за клиент-серверной архитектуры системы мои...
Я хочу, чтобы библиотека взаимодействовала с приложениями CLI на этих языках.(Это не по теме в SO?...
def(df:DataFrame):DataFrame = { val emptyDf = Seq.empty[(Long,String)].toDF() val p1 =...
У меня есть XML как NodeSeq.Я ищу вариант для обхода тегов внутри xml и присвоения порядкового...
У меня есть org.apache.spark.util.CollectionAccumulator[(Double, Double)] И я добавил в него строки...
Я хотел создать вложенный XML из CSV / DataFrame в scala spark.Я использую библиотеку Databricks...
Я столкнулся с этой проблемой, которую я не знаю, как решить ... У меня есть текст в форме квадрата