Skip to content

Commit 327aee0

Browse files
committed
Merge pull request #2 from ankurdave/label-propagation
Untabify
2 parents 0ac574c + 227a4d0 commit 327aee0

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

graphx/src/main/scala/org/apache/spark/graphx/lib/LabelPropagation.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -51,8 +51,8 @@ object LabelPropagation {
5151
(count1.keySet ++ count2.keySet).map { i =>
5252
val count1Val = count1.getOrElse(i, 0L)
5353
val count2Val = count2.getOrElse(i, 0L)
54-
i -> (count1Val + count2Val)
55-
}.toMap
54+
i -> (count1Val + count2Val)
55+
}.toMap
5656
}
5757
def vertexProgram(vid: VertexId, attr: Long, message: Map[VertexId, Long]) = {
5858
if (message.isEmpty) attr else message.maxBy(_._2)._1

0 commit comments

Comments
 (0)