Martin Kiefer created FLINK-1552:
------------------------------------
Summary: Allow secondary sorts in Vertex Centric Iteration
Key: FLINK-1552
URL: https://issues.apache.org/jira/browse/FLINK-1552
Project: Flink
Issue Type: Wish
Components: Gelly
Reporter: Martin Kiefer
Priority: Minor
The `VertexCentricIteration` class holds the logic to transform a
`VertexUpdateFunction` and a `MessagingFunction` into an iteration with two
CoGroup operators working on the set of messages and edges. Graph algorithms
can profit from implying an order on the edges or messages based on their value
and/or the vertex ID. This can be implemented easily making use of secondary
sorts. I would suggest extending the `VertexCentricIteration` to allow to
specify these kind of orderings optionally.
For example, this comes handy when it is necessary to find the edges with the
minimum or maximum value or the algorithm requires to pick the edge with lower
vertex ID for edges with equal value. Similar use cases might be found for
orders on the messages.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)