У меня есть устаревший смешанный проект Scala / Java. Он имеет собственный инструмент отображения...

Я определил пару классов case для представления JSON, но я не уверен, правильно ли я это сделал,...

Я новичок в Скале. Я пытаюсь отладить код Scala. Тестовые случаи написаны в самом большом...

Мой проект переключается с scala / spark на drools для проверки правил, но я никогда раньше не...

Рассмотрим следующий фрейм данных: val df = Seq("20140101", "20170619")

Я выполняю свои задания на Spark 2.2 в кластере с Mesos через spark-submit. Я заявляю: (в...

Мне нужно прочитать файлы ASCII, как показано ниже. Каждый элемент в строке разделен каким-либо...

Хотите функции row предполагается как вложенная структура. Ключи выходной карты должны быть полными...

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

Когда я использую задания и триггеры для планирования публикации сообщений, это работает val job =...

Я пытаюсь проанализировать объект класса в Scala для JSON для приложения Lagom для класса ниже он...

Я пробую простой пример публикации данных в Kafka и использования их с помощью Spark. Вот код...

В Spark у меня есть фрейм данных с одним столбцом, имеющим данные в следующем формате: « он = 1she...

Ниже приведен простой синтаксис для поиска строки в определенном столбце с использованием...

При использовании Scala и Spark 1.6.3 мое сообщение об ошибке: org.apache.spark.sql

val TimeFormat = 20:30:16 val count = 3500 Я отправляю вышеупомянутое значение через программу spark...

Я пытаюсь прочитать простой источник данных в java / scala spark. Я могу заставить его работать в...

Я использую Intellij. Я пытаюсь добавить основной класс Scala (называемый abc.def.ghi.MyClass) в...

Я использую JavaPoet для генерации классов по списку полей. Генерация конструктора, который берет...

У меня есть способ получить подмножество данных, которое работает: This works val subset_cols =...

Старый API-интерфейс структурированной потоковой передачи имеет MapWithStateDStream.stateSnapshots...

Я пытаюсь использовать функцию parMapN и не могу скомпилировать код. Если мой тип - IO, то это не...

Запрос http в файле ниже дает мне исключение BuferOverflowException. Я пробовал это, используя...

У меня есть следующий метод, написанный на Scala: def fillEmptyCells: Unit = { val hourIndex =...

Прочитав эту статью и понял, что примерно все функции после ключевого слова yield являются map...