Моя текущая работа заключается в создании процессов ETL с SparkSQL / Scala с использованием Spark 2

Я получаю сообщение об ошибке при использовании широковещательной переменной внутри функции...

Итак, я пытаюсь сгенерировать XML, который имеет структуру ниже. <n:Brands> <n:Brand>...

String folder = "/Users/test/data/*/*"; sparkContext.textFile(folder, 1).toJavaRDD()...

У меня есть кадр данных, как показано ниже: ---------------------+------------------------ text |...

У меня есть список строк в Python.Я создал из него блок данных с одним столбцом с таким кодом:...

У меня есть два фрейма данных, как показано ниже Содержимое DF1...

Можно ли добавить новый столбец в существующую таблицу искр с помощью команды ALTER TABLE? var...

Я пытаюсь использовать функцию createSataframe для sparksession, и я продолжаю получать сообщение...

Получение неправильного результата на счету. +--------+ |count(1)| +--------+ | 0| // Should not be...

У меня есть работающая UDF, которая создает побочный эффект, отправляет сообщение kafka в avro,...

У меня есть фрейм данных - df +----------+----+----+-------+-------+ |...

У меня есть сжатый файл JSON, который содержит массив JSON, что-то вроде этого:...

У меня есть требование для создания XML, который имеет структуру ниже <parent>...