...
No Format |
---|
public static class SumCombiner extends Combiner { @Override public BSPMessageBundle combine(Iterable<BSPMessage> messages) { BSPMessageBundle bundle = new BSPMessageBundle(); int sum = 0; Iterator<BSPMessage> it = messages.iterator(); while (it.hasNext()) { sum += ((IntegerMessage) it.next()).getData(); } bundle.addMessage(new IntegerMessage("Sum", sum)); return bundle; } } |
Job Configuration and Submission Interface
TODO:
...
— General Information —
In Apache Hama, you can implement your own BSP method by extending from org.apache.hama.bsp.BSP
class. Apache Hama provides in this class a user-defined function bsp()
that can be used to write your own BSP program.
...