pyspark.sql.SparkSession.getActiveSession¶
-
classmethod
SparkSession。getActiveSession( )→可選(pyspark.sql.session.SparkSession] ¶ -
返回活動
SparkSession當前線程返回的建設者- 返回
-
-
SparkSession -
火花會話如果一個活動會話存在當前線程
-
例子
> > >年代=SparkSession。getActiveSession()> > >l=((“愛麗絲”,1)]> > >抽樣=年代。sparkContext。並行化(l)> > >df=年代。createDataFrame(抽樣,(“名字”,“年齡”])> > >df。選擇(“年齡”)。收集()(行(年齡= 1))