Spark快速大数据分析——第四章键值对操作——两个Pair RDD的转化操作

键值对 两个Pair RDD 转化操作 val conf = new SparkConf().setMaster(local).setAppName(PairRDD) val sc = new SparkContext(conf) val lines = sc.parallelize(List((1, 2), (3, 4), (3, 6))) val lines_1 = sc.parallelize(List((3, 9))) 1、删掉RDD中与other RDD 中的键相同得元素 (1, 2), (3, 4), (3, 6) privateval subtra