pyspark.sql.SparkSession.builder.getOrCreate¶
-
構建器。getOrCreate( )→pyspark.sql.session.SparkSession¶ -
就現有的
SparkSession或者,如果沒有現有的,創造了一個新的基於選項集生成器。例子
該方法首先檢查是否有一個有效的全局缺省SparkSession,如果是的,返回。如果沒有有效的全局缺省SparkSession存在,該方法創建一個新的SparkSession和分配新創建的SparkSession隨著全球違約。
> > >s1=SparkSession。構建器。配置(“k1”,“v1”)。getOrCreate()> > >s1。相依。得到(“k1”)= =“v1”真正的
的配置SparkSession之後可以改變
> > >s1。相依。集(“k1”,“v1_new”)> > >s1。相依。得到(“k1”)= =“v1_new”真正的
現有SparkSession返回,這builder中指定的配置選項將被應用到現有的SparkSession。
> > >s2=SparkSession。構建器。配置(“k2”,“v2”)。getOrCreate()> > >s1。相依。得到(“k1”)= =s2。相依。得到(“k1”)= =“v1_new”真正的> > >s1。相依。得到(“k2”)= =s2。相依。得到(“k2”)= =“v2”真正的