Я создал простой Maven-проект Scala в Scala Ide затмения, используя следующие детали -...
Я имею дело с простой программой Scala, в которой я определил две вспомогательные функции: def...
Я хотел бы включить: eventually { assert(x == 0) } в verify { x == 0 } и по-прежнему получаю...
Я хочу запустить sql для своих данных паркета в spark, используя следующий код, val parquetDF =...
Я хочу преобразовать Spark DataFrame в другой DataFrame определенным образом следующим образом: У...
У меня есть игрушка DSL case class Logging[A](msg: String, action: A) case class Persist[A](msg:...
У меня проблема с CountVectorizer с paramGrid для Kfold.но я понятия не имею, в чем проблема,...
Я новичок в Spark и изучаю книгу "Расширенная аналитика с Spark".Код взят из примеров в книге.Когда...
У меня есть дата-фрейм с баллами за каждый день, и я хочу рассчитать суммарный балл для каждого...
У меня есть такие данные ORC (загруженные как изображение) Данные ORC при загрузке в фрейм данных...
У меня есть куча файлов паркета, и я создал внешние таблицы, используя Impala's CREATE EXTERNAL...
Я хочу создать класс случая scala, поля которого образуют карту.И, вот класс случая case class...
Я использую sbt package, чтобы создать .jar файл и отправить spark-submit , если я использую...
В книге Скалы Одерского у него есть пример, объясняющий частичные функции страницы 295. Он...
В Scala, Spark и многих других "больших данных" фреймворках, языках, библиотеках я вижу методы с...
У меня есть RDD [(String, Array [String])], и мне нужно скопировать данные внутри, чтобы увеличить...
Я пытаюсь записать DataFrame в формате json, однако продолжает появляться ошибка (не имеет значения...
У меня есть вопрос.У меня есть искровой датафрейм с несколькими столбцами, похожими на: id Color1...
Я начинающий со Scala. У меня есть датафрейм с 2 столбцами: первая - это дата, вторая - массив слов
У меня есть твиттер-будущее, и я хочу реализовать для этого onFailure обратный вызов. Сигнатура...
Я хотел бы иметь возможность смоделировать мою функцию вызова по имени с помощью ScalaMock, чтобы...
Предположим, у меня есть массив внутри JSON, и я пытаюсь сгладить его и сохранить в базе данных....
Scala 2.11.8, spark 2.0.1 Функция разнесения очень медленная - поэтому ищем альтернативный метод.Я...
Я пытаюсь реализовать пользовательскую функцию потерь (DL4J) , следуя этому примеру кода:...
Я изо всех сил пытаюсь придумать хорошую ментальную модель для , когда проблема хорошо подходит для...