[SPARK] 1.6 -> 2.1 foreachRDD, flatMap 사용법 변화 Spark 1.6.4▶ Scala 2.10.x JavaDStream B = A.flatMap(new FlatMapFunction() { public Iterable call(String line) { List data = new ArrayList(); return data; } }); B.foreachRDD(new Function() { public Void call(JavaRDD data) throws Exception { //Action return null; } }); Spark 2.1.0▶ Scala 2.11.x JavaDStream B = A.flatMap(new FlatMapFunction() { public Iterator call(String line) { List data = new Ar.. 더보기 이전 1 ··· 81 82 83 84 85 86 87 ··· 98 다음