You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hama.apache.org by Apache Wiki <wi...@apache.org> on 2011/12/16 09:28:21 UTC
[Hama Wiki] Trivial Update of "Combiner" by ChiaHungLin
Dear Wiki user,
You have subscribed to a wiki page or wiki category on "Hama Wiki" for change notification.
The "Combiner" page has been changed by ChiaHungLin:
http://wiki.apache.org/hama/Combiner?action=diff&rev1=1&rev2=2
Combiner in Hama BSP model is used to combine messages during [[SyncService|barrier sync]] stage. This can reduce messages sent to other peers because sending messages somehow incurs overhead[1].
== An example ==
- Combiner's usage can be seen in source code - CombinerExample.java, in which an user defined combiner - SumCombiner - sum up messages to be sent and add the result to BSPMessageBundle class. This decreases the total messages to just one IntegerMessage with a summary of all values.
+ Combiner's usage can be seen in source code - CombinerExample.java, in which an user defined combiner, SumCombiner, sums up messages to be sent and adds the result to BSPMessageBundle class. This decreases the total messages to just one IntegerMessage with a summary of all values.
{{{
public static class SumCombiner extends Combiner {
@@ -29, +29 @@
}}}
- Combiner actually get called in sync function,
+ Combiner actually gets called in sync function,
{{{