Когда я выполняю функцию в mapPartition набора данных (executeStrategy ()), он возвращает результат...

У меня есть класс дел в Scala: class StateCache(greeting: String, first_name: String, last_name:...

Я создал банку приложения Scala, используя maven-assembly-plugin. Теперь, когда я выполняю jar с...

Вот что я хочу сделать: В моем проекте Scala sbt я хочу опубликовать артефакт в моем локальном...

Я использую scala. У меня есть фрейм данных с миллионами строк и несколькими полями. Одним из полей...

У меня есть СДР, в котором указано "Клиент", "Потрачено". Я пытаюсь выполнить простую сортировку по...

Вот эскиз некоторого кода Scala 2.10 / Spark 1.6.3, который я запускаю: def processText(df:...

В следующем коде я ожидал, что компилятор определит, что output определяется либо в разделе if,...

Я пытаюсь выполнить операцию отображения на Spark DStream в приведенном ниже коде: val...

В моем приложении Spark Streaming я получил эту ошибку, когда приложение считывало поток файлов....

Я работаю в Spark и использую Scala У меня есть два CSV-файла, один с именами столбцов, а другой с...

Я новичок в Spark Framework и мне нужна помощь! Предположим, что первый DataFrame (df1) хранит...

Я читаю все один за другим файлы, которые хранятся в структуре каталогов как YY=18/MM=12/DD=10 и...

У меня есть столбец типа Json в MySql, и я использую Scala с Slick. Как я могу предоставить...

У меня есть искровое приложение. Мой пример использования - позволить пользователям определять...

@ DebanjanB - Привет. Я автоматизировал загрузку веб-сайта с помощью селена Chrome драйвер. Однако,...

Я не понимаю, как я могу объединить 2 таких DataFrame друг с другом. Первый DataFrame хранит...

У меня есть такой фрейм данных: +-----+---------+---------+ |Categ| Amt| price|...

trait Node[N<:Node[N]] { self:N => } trait A extends Node[A] trait B { def list:List[Node[_]]...

У меня есть фрейм данных с 27770 записями в scala с использованием spark. Этот информационный кадр...

Я опытный программист в ruby, python и javascript (в частности, back-end node.js), я работал в java...

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

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

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

У меня есть рекурсивная структура данных. Spark выдает эту ошибку: Exception in thread...