[
https://issues.apache.org/jira/browse/HAMA-637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Suraj Menon updated HAMA-637:
-----------------------------
Description:
We should experiment the effectiveness of this feature. Instead of a peer
sending message to each of the peers that logically a part of a group(active
vertices of graph, members of group in a cluster, etc.)
The API could be:
{code}
peer.sendMessageToGroup(String group, Writable message);
{code}
This should result in finding all the peers that are members of that group and
send message to each of the peers in the group.
Peers can change their membership status using the following API.
The guarantee of the group membership is ensured only in the next superstep.
{code}
peer.registerWithGroup(String group, Writable message);
peer.deregisterFromGroup(String group, Writable message);
{code}
For now we can try using Zookeeper for this solution.
was:
We should experiment how effective it would be to implement this feature.
Instead of a peer sending message to each of the peers that logically a part of
a group(active vertices of graph, members of group in a cluster, etc.)
The API could be:
{code}
peer.sendMessageToGroup(String group, Writable message);
{code}
This should result in finding all the peers that are members of that group and
send message to each of the peers in the group.
Peers can change their membership status using the following API.
The guarantee of the group membership is ensured only in the next superstep.
{code}
peer.registerWithGroup(String group, Writable message);
peer.deregisterFromGroup(String group, Writable message);
{code}
For now we can try using Zookeeper for this solution.
> Implement Group membership API for tasks
> ----------------------------------------
>
> Key: HAMA-637
> URL: https://issues.apache.org/jira/browse/HAMA-637
> Project: Hama
> Issue Type: New Feature
> Components: bsp core
> Reporter: Suraj Menon
>
> We should experiment the effectiveness of this feature. Instead of a peer
> sending message to each of the peers that logically a part of a group(active
> vertices of graph, members of group in a cluster, etc.)
> The API could be:
> {code}
> peer.sendMessageToGroup(String group, Writable message);
> {code}
> This should result in finding all the peers that are members of that group
> and send message to each of the peers in the group.
> Peers can change their membership status using the following API.
> The guarantee of the group membership is ensured only in the next superstep.
> {code}
> peer.registerWithGroup(String group, Writable message);
> peer.deregisterFromGroup(String group, Writable message);
> {code}
> For now we can try using Zookeeper for this solution.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
