spark会议
getActiveSession
返回活动spark会议当前线程由构建者返回
spark会话,如果活动会话存在当前线程
实例
>>>s级=spark会议.getActiveSession(b)>>>I级=[(c)项爱丽丝,一号南都市>>>dd=s级.sparkContext.并行化高山市I级)>>>df=s级.创建DataFrame高山市dd,[名名,位元)>>>df.选择高山市高龄).集合(b)ow(age=1)]
前一
pyspark.sql.SparkSession.createDataFrame
下一个
pyspark.sql.SparkSession.newSession