小编PC9*_*527的帖子

如何在代码的任何位置获取当前的SparkSession

我在main()函数中创建了一个会话,如下所示:

val sparkSession = SparkSession.builder.master("local[*]").appName("Simple Application").getOrCreate()
Run Code Online (Sandbox Code Playgroud)

现在,如果我想配置应用程序或访问属性,我可以sparkSession在同一个函数中使用局部变量.

如果我想访问此sparkSession在同一项目中的其他地方一样project/module/.../.../xxx.scala.我该怎么办?

scala apache-spark

12
推荐指数
2
解决办法
8274
查看次数

标签 统计

apache-spark ×1

scala ×1