hive-site.xml
)正确配置,并且所有必要的Hive依赖已经添加到项目的classpath中。spark.executor.memory
和spark.driver.memory
参数。// 创建SparkSession
val spark = SparkSession.builder()
.appName("example")
.master("local[*]")
.getOrCreate()
// 使用SparkSession进行数据处理
import spark.implicits._
val df = spark.read.option("header", "true").csv("data.csv")
df.show()
// 关闭SparkSession
spark.stop()
领取专属 10元无门槛券
手把手带您无忧上云