pair的格式 为 (a,1)或 (c,23)的形式,其中 a和1可以为任意类型
简单示例1
JavaRDD<String> RDD_3 = javaSparkContext.parallelize(Arrays.asList("aa", "bb", "cc", "dd"));
JavaPairRDD<String, Integer> stringIntegerJavaPairRDD1 = RDD_3.mapToPair(new PairFunction<String, String, Integer>() {@Overridepublic Tuple2<String, Integer> call(String s) throws Exception {return new Tuple2<>(s, 1);}});
System.out.println(stringIntegerJavaPairRDD1.collect());------------------返回的结果
(aa,1), (bb,1), (cc,1), (dd,1)