Skip to content

Commit

Permalink
Merge pull request #2 from ankurdave/label-propagation
Browse files Browse the repository at this point in the history
Untabify
  • Loading branch information
haroldsultan committed May 29, 2014
2 parents 0ac574c + 227a4d0 commit 327aee0
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -51,8 +51,8 @@ object LabelPropagation {
(count1.keySet ++ count2.keySet).map { i =>
val count1Val = count1.getOrElse(i, 0L)
val count2Val = count2.getOrElse(i, 0L)
i -> (count1Val + count2Val)
}.toMap
i -> (count1Val + count2Val)
}.toMap
}
def vertexProgram(vid: VertexId, attr: Long, message: Map[VertexId, Long]) = {
if (message.isEmpty) attr else message.maxBy(_._2)._1
Expand Down

0 comments on commit 327aee0

Please sign in to comment.