Hi,
you can actually implement each of the algorithm phases in a separate
superstep.
Inside the VertexUpdateFunction and the MessagingFunction, you can easily
check in which superstep you are by calling the "getSuperstepNumber()"
method. For example, if the superstep number is odd, you execute ph
Hello,
In vertex-centric Iteration, in each iteration, the vertices sends and
recieves messages once.
However, to implement Affinity Propogation algortihm, I need to update
responsibility and availability in one iteration(superstep):
1, each vertex send and recieves messages from neigbor vertic
hagersaleh created FLINK-1872:
-
Summary: How can generation dataset in flink automatic depend on
number of filed and data type
Key: FLINK-1872
URL: https://issues.apache.org/jira/browse/FLINK-1872
Projec
Vasia Kalavri created FLINK-1871:
Summary: Add a Spargel to Gelly migration guide
Key: FLINK-1871
URL: https://issues.apache.org/jira/browse/FLINK-1871
Project: Flink
Issue Type: Task
