[
https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15266536#comment-15266536
]
ASF GitHub Bot commented on FLINK-2044:
---------------------------------------
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1956#issuecomment-216226071
There is no way to get the aggregated value of the current superstep, as
the aggregation happens at the superstep barrier. What you could do is
normalize the vertex value in the `MessagingFunction` of the next superstep.
E.g. say in superstep `i` you need to set each vertex value to `v / sum(i)`.
You can instead set it to `v` and then propagate `v / sum(i)` in the scatter
phase of superstep `i+1`. Would that work?
> Implementation of Gelly HITS Algorithm
> --------------------------------------
>
> Key: FLINK-2044
> URL: https://issues.apache.org/jira/browse/FLINK-2044
> Project: Flink
> Issue Type: New Feature
> Components: Gelly
> Reporter: Ahamd Javid
> Assignee: GaoLun
> Priority: Minor
>
> Implementation of Hits Algorithm in Gelly API using Java. the feature branch
> can be found here: (https://github.com/JavidMayar/flink/commits/HITS)
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
