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