6 ,spark 分区 ,分区与线程 ,遍历分区数据

1 ,当前 rdd 包含多少分区 : rdd2.getNumPartitions 2 ,读文件后,天然分区 : 无规律 代码 : object SparkDemo08_reduceBykey { def main(args: Array[String]): Unit = { // 1 ,参数对象 val conf = new SparkConf().setA
相关文章
相关标签/搜索