org.apache.giraph.master

Class TestSwitchClasses.MinimumMessageCombiner

java.lang.Object

org.apache.giraph.master.TestSwitchClasses.MinimumMessageCombiner

All Implemented Interfaces:

MessageCombiner<org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.IntWritable>

Enclosing class:

TestSwitchClasses

public static class TestSwitchClasses.MinimumMessageCombiner
extends Object
implements MessageCombiner<org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.IntWritable>

Constructor Summary

Constructors

Constructor and Description
MinimumMessageCombiner()

Method Summary

Modifier and Type	Method and Description
void	combine(org.apache.hadoop.io.IntWritable vertexIndex, org.apache.hadoop.io.IntWritable originalMessage, org.apache.hadoop.io.IntWritable messageToCombine)
org.apache.hadoop.io.IntWritable	createInitialMessage()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MinimumMessageCombiner

public MinimumMessageCombiner()

Method Detail

combine

public void combine(org.apache.hadoop.io.IntWritable vertexIndex,
                    org.apache.hadoop.io.IntWritable originalMessage,
                    org.apache.hadoop.io.IntWritable messageToCombine)

Specified by:

combine in interface MessageCombiner<org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.IntWritable>

createInitialMessage

public org.apache.hadoop.io.IntWritable createInitialMessage()

Specified by:

createInitialMessage in interface MessageCombiner<org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.IntWritable>