Надеюсь, это поможет!

я есть приложение Spark, которое использует новый API Spark 2.0 сSparkSession, Я строю это приложение поверх другого приложения, которое используетSparkContext, Я хотел бы пройтиSparkContext на мое приложение и инициализироватьSparkSession используя существующиеSparkContext.

Однако я не мог найти способ, как это сделать. я нашел этоSparkSession конструктор сSparkContext является частным, поэтому я не могу инициализировать его таким образом, и строитель не предлагает никакихsetSparkContext метод. Как вы думаете, существует ли какое-то решение?

Ответы на вопрос(6)

Ваш ответ на вопрос