Github user andralungu commented on the pull request:
https://github.com/apache/flink/pull/537#issuecomment-99232613
Hey @vasia ,
Everyone is acting as though I do not want to make these methods
user-freindly. I do :), it's just not possible.
Keep in mind that in the VertexUpdateFunction and in the MessagingFunction
you can only access the vertex in the updateVertex() and sendMessages()
methods.
getDirection(), getBroadcastSet() return a single value for all the
vertices. getDegree() returns one value for each of the vertices. As
previously implied, you cannot access the vertex in these classes. The only
very ugly solution is to give it the entire DataSet and to constantly filter
it. You basically have the degree of the vertex in the Tuple3, but this
information is hidden from the user.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
