...
The default implementation of Apache Hama is org.apache.hama.bsp.message.HadoopMessageManagerImplHamaMessageManagerImpl
which uses Hadoop's RPC mechanisms.
...
If you're interested in implementing another framework for communication please let us know at the dev-mailing list or post in this JIRA issue.
Configuring
Your implemenation can be set by the configuration values:
No Format |
---|
hama.messangermessenger.class |
Make sure this configuration is consistent on every host in every configuration. And make sure that the class has a public default constructure since it will be instantiated via reflection.