2016-04-08 4 views
-2

私は火花の初心者です マップを作成する前にマップ上の最初の文字を確認する方法を教えてくださいRDD(word.charAt(0)が存在する場合)その結果RDDはこの場合のみ、(RDD[T]T => Boolean機能)述語を満たすレコードが含まれています - 非空の文字列を:他に行き、このレコードはgroupByKey火花マップでelseを使用するreduce

val mapReduce = splitFile.map(word => (word.charAt(0), word.length)).groupByKey() 
+0

RDDのみですべての変換を行い、フィルタ関数foを使用します。 – banjara

答えて

0

使用filterに渡していません。

splitFile 
    .filter(!_.isEmpty) 
    .map(word => (word.charAt(0), word.length)) 
    .groupByKey()