[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15224010#comment-15224010
]
Vasia Kalavri commented on FLINK-1707:
--------------------------------------
Hi [~joseprupi],
I assume you're working with a scatter-gather iteration, right?
- If a vertex calls {{setNewVertexValue}}, then it will be added in the workset
for the next iteration. There is no check whether the value has actually
changed, so even if it's the same value, the vertex will still be activated.
- Sending a message to a deactivated vertex will trigger its
{{VertexUpdateFunction}}. If during the computation the vertex updates its
value, then it will be activated. Note that in a scatter-gather iteration
messaging and vertex-update happen during the _same_ superstep.
Also, note that I have recently merged a [vertex-centric iteration
abstraction|https://ci.apache.org/projects/flink/flink-docs-master/apis/batch/libs/gelly.html#vertex-centric-iterations]
into Gelly. This abstraction is much closer to the Giraph abstraction, so you
might find it useful. Let me know if you have further questions.
> Add an Affinity Propagation Library Method
> ------------------------------------------
>
> Key: FLINK-1707
> URL: https://issues.apache.org/jira/browse/FLINK-1707
> Project: Flink
> Issue Type: New Feature
> Components: Gelly
> Reporter: Vasia Kalavri
> Assignee: Josep Rubió
> Priority: Minor
> Labels: requires-design-doc
> Attachments: Binary_Affinity_Propagation_in_Flink_design_doc.pdf
>
>
> This issue proposes adding the an implementation of the Affinity Propagation
> algorithm as a Gelly library method and a corresponding example.
> The algorithm is described in paper [1] and a description of a vertex-centric
> implementation can be found is [2].
> [1]: http://www.psi.toronto.edu/affinitypropagation/FreyDueckScience07.pdf
> [2]: http://event.cwi.nl/grades2014/00-ching-slides.pdf
> Design doc:
> https://docs.google.com/document/d/1QULalzPqMVICi8jRVs3S0n39pell2ZVc7RNemz_SGA4/edit?usp=sharing
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
