Я обрабатываю большое количество строк из базы данных или файла, используя Apache Spark. Часть...

Я пытаюсь запустить на Hadoop с Spark, но у меня появляется ошибка «Не удается загрузить основной...

У меня есть датафрейм с двумя столбцами с данными, как показано ниже +----+-----------------+...

Вопрос, который у меня возникает, - можем ли мы использовать ключевые аргументы вместе с UDF в...

Извините за вопрос noob, у меня в SparkSQL есть такой фрейм данных: id | name | data...

Как я могу обновить столбец m_name с помощью алгоритма Левенштейна, чтобы заменить нули?...

Я пытаюсь запустить простую запись данных в пример ElasticSearch. Тем не менее, я получаю эту...

Мне нужно иметь возможность зарегистрировать udf из строки, которую я получу от веб-службы, т.е. во...

Я пытаюсь запустить простую программу Phoenix, которая отлично работает в локальном режиме,...

У меня есть два разных RDD, и я применяю foreach к ним обоим и отмечаю разницу, которую не могу...

Я пытаюсь создать постоянную функцию в spark, используя geomesa-spark-jts. Geomesa-spark-jts имеет...

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

У меня есть два кадра данных: edges = srcId dstId timestamp 1 4 1346564657 1 2 1345769687 2 4...

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

В apache spark разрешено загружать наборы данных из разных источников. Насколько я понимаю,...

Я пытаюсь прочитать таблицу из MariaDB4J через jdbc, используя следующую команду:...

Это мой фрейм данных без формата данных...

Использование Spark Streaming для чтения и обработки сообщений от Kafka и записи в HDFS - Hive. Так...

Когда я запускаю локальную программу spark2x из eclipse, я получаю сообщение об ошибке: Исключение...

образец линии: { "расширение": "имена, схемы", "centralid": 10, "centralloc": "Балх", компоненты: [...

В настоящее время я использую spark для обработки документов. В моем распоряжении два сервера...

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

Мы используем Hive на Spark, и мы хотим сделать все на улье, и используем spark для расчета. Это...

У меня есть несколько искровых тестов, которые я нормально выполняю удаленно через maven на spark 1

У меня есть задание spark streaming (2.1), работающее в режиме кластера, и я продолжаю сталкиваться...