6 ,spark 分區 ,分區與線程 ,遍歷分區數據

1 ,當前 rdd 包含多少分區 : rdd2.getNumPartitions 2 ,讀文件後,天然分區 : 無規律 代碼 : object SparkDemo08_reduceBykey { def main(args: Array[String]): Unit = { // 1 ,參數對象 val conf = new SparkConf().setA
相關文章
相關標籤/搜索