public static class TestSwitchClasses.MinimumMessageCombiner extends Object implements MessageCombiner<org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.IntWritable>
Constructor and Description |
---|
MinimumMessageCombiner() |
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() |
public void combine(org.apache.hadoop.io.IntWritable vertexIndex, org.apache.hadoop.io.IntWritable originalMessage, org.apache.hadoop.io.IntWritable messageToCombine)
combine
in interface MessageCombiner<org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.IntWritable>
public org.apache.hadoop.io.IntWritable createInitialMessage()
createInitialMessage
in interface MessageCombiner<org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.IntWritable>
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.