在2.0中,
FlatMapFunction.call()返回
Iterator而不是
Iterable。试试这个:
JavaRDD<String> javaRDDWords = javaRDDLines.flatMap(line -> Arrays.asList(line.split(" ")).iterator())
在2.0中,
FlatMapFunction.call()返回
Iterator而不是
Iterable。试试这个:
JavaRDD<String> javaRDDWords = javaRDDLines.flatMap(line -> Arrays.asList(line.split(" ")).iterator())