当前位置: 代码迷 >> 综合 >> spark常用RDD算子 - mapToPair
  详细解决方案

spark常用RDD算子 - mapToPair

热度:62   发布时间:2024-02-01 19:04:50.0

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)

 

  相关解决方案