Я пытаюсь запустить мой искровой код, но у меня проблема: Exception in thread "main" java

Мне нужно прочитать CSV-файл из hdfs, затем мне нужно применить логику, согласно которой каждый...

Я пытаюсь отфильтровать строки набора данных cosmos db. Я создаю представление для набора данных....

Я хочу записать данные ORC во внешнюю таблицу Hive из фрейма данных Spark.Когда я сохраняю фрейм...

Я хочу создать сервис, в котором он отправляет HTTP-запрос на определенный URL-адрес, и если он не...

Я работаю над настройкой категориальных переменных для моделей с искровым ML. Вместо столбца с...

У меня много потребностей для преобразования существующих таблиц в Impala (не в Hive) в электронную...

Я пытаюсь использовать приемник foreach при записи моего кадра данных в таблицу кустов: // dp is my...

Мне нужно использовать внешнюю библиотеку в функции mapPartition RDD, и для этого я должен вызвать...

Вот примерные данные, которые нужно разделить на два конкретных столбца { "tags": [ {...

У меня есть модуль в intellij, где я могу создавать основные методы в java, которые отлично...

Есть ли способ переименовать имена столбцов в наборе данных с использованием аннотаций Джексона при...

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

Я пытался запустить пример John Snow Spark-NLP из этого репозитория: https://github

У меня есть функция, которая выглядит так: private def readDS[T <: Product : TypeTag](path:...

В приведенном ниже коде Scala Spark мне нужно найти количество и его процент от значений различных...

Мне просто любопытно. Я пытаюсь сделать строки сопоставления с образцом в Scala способом Haskell...

def backGroundTask:IO[Unit]={ IO { //Time consuming task } } Как выполнить эту задачу с нетерпением...

У меня есть две структуры; 'pointsArray' типа (Double, Double) и 'listOfBBs' класса типа List...

Я хочу, чтобы UNIX Epoch Time (Posix Time, Unix Time) строки в некотором pattern, строка была в...

Я успешно настроил zookeeper и spark в 3 разных виртуальных коробках. Запуск zookeeper и spark...

Я создаю новый Блокчейн-сервер с использованием Hadoop и Apache Spark, я проверил его как Object,...

У меня есть файл конфигурации scala, созданный с помощью библиотеки pureconfig . Я хотел бы...

Рассмотрим следующий пример: import cats.Functor import cats.effect.{Concurrent, Timer} import cats

Я новичок в игровой рамке. Я создал код, который переводит счет в реальном времени с брокера Кафки...