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

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

val sparkSession = SparkSession.builder.master("local[*]").appName("Simple Application").getOrCreate()

现在，如果要配置应用程序或访问属性，则可以在同一函数中使用局部变量sparkSession。

如果我想在同一项目的其他位置（例如sparkSession）访问此project/module/.../.../xxx.scala，该怎么办。我该怎么办？

最佳答案

创建会话（任何位置）后，您可以安全地使用：

SparkSession.builder().getOrCreate()

只要会话仍然存在，就可以在代码中的任何地方获得（相同）会话。 Spark维护一个活动会话，因此除非它被停止或崩溃，否则您将获得相同的会话。

关于scala - 如何在代码的任何位置获取当前的SparkSession？，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/44502872/