写一个SparkSession获取工具类
可以使用以下代码获取一个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的应用程序中。
原文地址: https://www.cveoy.top/t/topic/xVf 著作权归作者所有。请勿转载和采集!