可以使用以下代码获取一个SparkSession:

import org.apache.spark.sql.SparkSession

object SparkSessionUtils {

  def createSparkSession(appName: String): SparkSession = {
    SparkSession.builder()
      .appName(appName)
      .getOrCreate()
  }

}

然后可以在应用程序中使用以下代码来获取SparkSession:

val spark = SparkSessionUtils.createSparkSession("MyApp")

这个工具类可以用于任何需要使用SparkSession的应用程序中。

写一个SparkSession获取工具类

原文地址: https://www.cveoy.top/t/topic/xVf 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录