스택큐힙리스트

JavaSparkContext spark = new JavaSparkContext( new SparkConf().setJars(...).setSparkHome....); JavaRDD file = spark.textFile(hdfs://...); // 단계1 JavaRDD words = file.flatMap(new FlatMapFunction() { public Iterable call(String s) { return Arrays.asList(s.split( )); } }); // 단계2 JavaPairRDD pairs = words.map(new PairFunction() { public Tuple2 call(String s) { return new Tuple2(s, 1); } }); // 단계3 ..