¿Qué tipo de directory debo search para search mapnetworkinguce código fuente en chispa?

Estoy estudiando sobre mapnetworkinguce y spark, y tengo curiosidad sobre cómo funciona el process de chispa. En consecuencia, estoy buscando eso en ' https://github.com/apache/spark ', pero viendo ese sitio, no pude get ninguna pista sobre qué directory debería search para ver el código fuente mapnetworkinguce.

Quiero decir en el siguiente código, hay funciones .flatMap (), .map () y .networkinguceByKey (). Definitivamente, quiero ver el código fuente sobre estas funciones.

val textFile = sc.textFile("hdfs://...") val counts = textFile.flatMap(line => line.split(" ")) .map(word => (word, 1)) .networkinguceByKey(_ + _) counts.saveAsTextFile("hdfs://...") 

gracias

La abstracción básica en Spark es el RDD . Si busca en core/src/main/scala/org/apache/spark/rdd/RDD.scala , puede encontrar map() , flatMap() y filter() , entre otros.

Pero no son terriblemente emocionantes.