1 个回答
通过partitons.size即可看到,例如:
val data = sc.parallelize(List(1,2,3,4,56,7,87,9))
println("分区数是:"+data.partitions.size)
发布于:2年前 (2022-12-08) IP属地:四川省
我来回答
您需要 登录 后回答此问题!