🌈 搜索
📅 最后修改于: 2022-03-11 14:59:14.293000 🧑 作者: Mango
val spark:SparkSession = SparkSession.builder() .master("local[5]") .appName("SparkByExamples.com") .getOrCreate() val df = spark.range(0,20) println(df.rdd.partitions.length) df.write.mode(SaveMode.Overwrite)csv("partition.csv")