類型不匹配：無法從JavaRDD <Object>轉換爲JavaRDD <String>

Question

我剛開始學習Apache Spark並執行一個項目。第一個任務是讀取包含多行文本的文件並獲取字典。根據我的理解，我寫了下面的代碼：

JavaRDD<String> lines = spark.sparkContext().textFile("tokens.txt",10).toJavaRDD(); 
JavaRDD<String> dictionary = lines.flatMap(l -> l.split(" ")); 

我也試過

JavaRDD<String> dictionary = lines.flatMap(l -> Arrays.asList(l.split(" "))); 

但是Eclipse是給我這個錯誤：

Type mismatch: cannot convert from JavaRDD<Object> to JavaRDD<String>

我在做什麼錯？

Answer 1

我只是想通了。需要在最後調用iterator（）。

JavaRDD<String> dictionary = lines.flatMap(l -> Arrays.asList(l.split(" ")).iterator());