removing completely unnecessary map operation.
This commit is contained in:
parent
003f8a505d
commit
09ea661bbb
|
@ -55,7 +55,6 @@ object GraphLoader {
|
||||||
private def fromEdges[ED: ClassManifest](edges: RDD[Edge[ED]]): GraphImpl[Int, ED] = {
|
private def fromEdges[ED: ClassManifest](edges: RDD[Edge[ED]]): GraphImpl[Int, ED] = {
|
||||||
val vertices = edges.flatMap { edge => List((edge.srcId, 1), (edge.dstId, 1)) }
|
val vertices = edges.flatMap { edge => List((edge.srcId, 1), (edge.dstId, 1)) }
|
||||||
.reduceByKey(_ + _)
|
.reduceByKey(_ + _)
|
||||||
.map{ case (vid, degree) => (vid, degree) }
|
|
||||||
GraphImpl(vertices, edges, 0)
|
GraphImpl(vertices, edges, 0)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue