Spark mapPartitions和map

楔子 Spark 两个API map public static void mapMethod() { JavaRDD<String> rdd = sc.parallelize(Arrays.asList("hello", "spark", "hadoop", "李丰", "帅", "弓", "瑞", "杰", "青"), 3); JavaRDD<String> map = rdd.map(

>>阅读原文<<