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(

>>阅读原文<<