-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 groupByKey
Kıvılcım haritasındaki diğer kullanımını azaltın
val mapReduce = splitFile.map(word => (word.charAt(0), word.length)).groupByKey()
tüm dönüşümlerinizi sadece RDD'de yapın, char0 varsa – banjara