val sparkSession: SparkSession = SparkSession.builder.appName("session creation basan") .config("spark.sql.sources.partitionOverwriteMode", "dynamic") .config("hive.exec.dynamic.partition.mode", "nonstrict") .config("spark.sql.orc.impl", "native") .config("spark.sql.orc.enableVectorizedReader", "true").master("local[*]").getOrCreate()
No comments:
Post a Comment