0
私はApache Sparkの学習を始め、プロジェクトを始めました。最初のタスクは、複数の行のテキストを含むファイルを読み込んで辞書を取得することです。タイプの不一致:JavaRDD <Object>からJavaRDDに変換できません<String>
が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>
何をしているのですか?私の理解に基づいて、私は次のコードを記述しますか
なぜ 'l - > l.split(" ")'が 'flatMap()'の有効な引数になるのですか? – shmosel
@shmosel私がスパークを初めて習得して以来、なぜ正しい議論になるべきなのか分かりません。 – user7344209
バージョンによって異なります。しかし、あなたは私にあなたに言う必要はありません。ドキュメントを確認してください。 – shmosel