Spark RDD的数据分区

数据分区 1.只有Key-Value类型的RDD才有数据分区器,非Key-Value类型的RDD分区器为Nonejava 2.每一个RDD的分区ID范围为:0~numPartitions-1apache def main(args: Array[String]): Unit = { var conf = new SparkConf().setAppName("master").setMas
相关文章
相关标签/搜索