Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/537#discussion_r27255825
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/Graph.java ---
@@ -1118,17 +1118,61 @@ public boolean filter(Edge<K, EV> edge) {
}
/**
- * Create a Vertex-Centric iteration on the graph.
- *
+ * Create a Vertex-Centric iteration on the graph. inDegrees, outDegrees
+ * and the total number of vertices are set here in order to be
retrieved
+ * later on within the iteration.
+ *
+ * Also, The user can define the direction in which the updates are
performed
+ * and in which the messages are sent. The function below tackles the
regular
+ * use-case where updates of the in-neighbors are used to calculate
state
+ * and messages are sent to out-neighbors.
+ *
* @param vertexUpdateFunction the vertex update function
* @param messagingFunction the messaging function
* @param maximumNumberOfIterations maximum number of iterations to
perform
* @return
*/
- public <M> VertexCentricIteration<K, VV, M, EV>
createVertexCentricIteration(
+ public <M, NV extends Serializable> VertexCentricIteration<K, VV, M,
EV> createVertexCentricIteration(
--- End diff --
NV is never used?
---
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.
---
