Spark 2.0.0 Arrays.asListが機能しない - 互換性のないタイプ

Question

次のコードはSpark 1.5.2では動作しますが、Spark 2.0.0では動作しません。私はJava 1.8を使用しています。

final SparkConf sparkConf = new SparkConf(); 
sparkConf.setMaster("local[4]"); // Four threads 
final JavaSparkContext javaSparkContext = new JavaSparkContext(sparkConf); 
final JavaRDD<String> javaRDDLines = javaSparkContext.textFile("4300.txt"); 
final JavaRDD<String> javaRDDWords = javaRDDLines.flatMap(line -> Arrays.asList(line.split(" "))); 

私はスパークのAPIが変更または何か他のものしているかどうかを把握することができませんエラー

次取得。助けてください。ありがとう。

Answer 1

2.0では、FlatMapFunction.call()はIterableではなくIteratorを返します。これを試してください：

JavaRDD<String> javaRDDWords = javaRDDLines.flatMap(line -> Arrays.asList(line.split(" ")).iterator())