2016-04-08 15 views
-2

Ben kıvılcım acemi oldum, harita oluşturmadan önce haritadaki ilk karaktere nasıl bir göz attığımı kontrol edin RDD (eğer word.charAt (0) var), ve eğer durum Ortaya çıkan RDD sadece bu durumda, (bir RDD[T] için T => Boolean fonksiyonu) yüklemi tatmin kayıtları içerecektir - boş olmayan dizeler: başka gidin, bu kayıt groupByKeyKıvılcım haritasındaki diğer kullanımını azaltın

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

tüm dönüşümlerinizi sadece RDD'de yapın, char0 varsa – banjara

cevap

0

Kullanım filter için geçemiyor:

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