[ https://issues.apache.org/jira/browse/FLINK-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14352260#comment-14352260 ]
ASF GitHub Bot commented on FLINK-1514: --------------------------------------- Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/408#issuecomment-77774282 The vertex-centric iterations use semantic annotations a lot to save sorting/partitioning where possible. This results in a plan for the vertex-centric iterations that partitions one and sorts one, despite the fact that it uses wither two coGroups or 2 joins plus a reduce. I think this would help big time here as well. In general, plan optimization may be something that Gelly could take a look at. > [Gelly] Add a Gather-Sum-Apply iteration method > ----------------------------------------------- > > Key: FLINK-1514 > URL: https://issues.apache.org/jira/browse/FLINK-1514 > Project: Flink > Issue Type: New Feature > Components: Gelly > Affects Versions: 0.9 > Reporter: Vasia Kalavri > Assignee: Daniel Bali > > This will be a method that implements the GAS computation model, but without > the "scatter" step. The phases can be mapped into the following steps inside > a delta iteration: > gather: a map on each < srcVertex, edge, trgVertex > that produces a partial > value > sum: a reduce that combines the partial values > apply: join with vertex set to update the vertex values using the results of > sum and the previous state. -- This message was sent by Atlassian JIRA (v6.3.4#6332)