丹阳网站建设效果优化seo网站

一、 介绍

1. SparkSession是Spark 2.0中引入的新概念，它是Spark SQL、DataFrame和Dataset API的入口点，是Spark编程的统一API，也可看作是读取数据的统一入口；
2. 它将以前的SparkContext、SQLContext和HiveContext组合在一起，使得用户可以在一个统一的接口下使用Spark的所有功能。
3. 需要注意的是，SparkSession是一个重量级的对象，创建和销毁的代价较高，因此在项目中应该尽可能地重用同一个SparkSession对象。
4. 在I/O期间，在构建器中设置的配置项将自动同步到Spark和Hadoop。

二、如何使用

# 在项目中初始化SparkSession，可以按照以下步骤进行：
# 1、导入必要的包：
import org.apache.spark.sql.SparkSession
# 2、创建SparkSession对象：
val spark = SparkSession.builder  # 使用builder()方法创建一个SparkSession.Builder对象，构建器将自动重用现有的SparkSession；如果不存在则会创建一个SparkSession.appName("xxx").config("hive.exec.dynamic.partition", "true")  # 设置分区.config("hive.exec.dynamic.partition.mode", "nonstrict") # 设置hive是动态写入的方式.config("spark.sql.broadcastTimeout", 3000).config("spark.sql.sources.partitionOverwriteMode", "dynamic")  # 设置hive动态写分区.config("spark.checkpoint.dir", "/user/vc/projects_prod/checkpoint/data")  # 设置checkpoint的路径.enableHiveSupport().getOrCreate()# 3、使用SparkSession对象进行数据操作：
val df = spark.read.json("path/to/json/file")
df.show()

三、sparkSession的配置参数参考
https://blog.csdn.net/u010569893/article/details/111356664