Мы переносим наши программы Scala Spark с 1.6.3 на 2.2.0.Рассматриваемая программа состоит из...

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

Я использую Stream-Streaming (версия 2.2) в кластере пряжи и пытаюсь включить динамическое...

У меня есть следующий код.df3 создается с использованием следующего кода. Я хочу получить...

Мой текстовый файл содержит следующие данные: 10,14,16,19,52 08,09,12,20,45 55,56,70,78,53 Я хочу...

У меня есть вопрос относительно структурированной потоковой передачи Spark в потоке Kafka. У меня...

Я пытаюсь прочитать текстовый файл в spark 2.3, используя python, но я получаю эту ошибку.Это...

У меня есть файл Excel с 4 листами. На каждом рабочем листе первые 3 строки являются пустыми, то...

******* ОБНОВЛЕНИЕ ******** Как предложено в комментариях, я исключил несущественную часть кода: Мои...

Я пытаюсь поместить некоторые данные в kudu, но рабочий не может найти токен kerberos, поэтому я не...

Я пытаюсь отредактировать конфигурацию размера блока hadoop через оболочку spark, чтобы...

Я хочу перенести код pyspark с 1.6 на 2.x.В 1.6 я использовал синтаксис input_df

Я надеюсь сгенерировать план объяснения / выполнения в Spark 2.2 с некоторыми действиями над кадром...

При создании DataFrame из файла CSV, если включена опция multiLine, некоторые столбцы файла...

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

У меня есть данные в Кассандре (3.11.2), которые также являются моими df: Данные в Кассандре: id |...