public class NullMessageCombiner extends Object implements MessageCombiner<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.NullWritable>
Constructor and Description |
---|
NullMessageCombiner() |
Modifier and Type | Method and Description |
---|---|
void |
combine(org.apache.hadoop.io.WritableComparable vertexId,
org.apache.hadoop.io.NullWritable null1,
org.apache.hadoop.io.NullWritable null2)
Combine messageToCombine with originalMessage, by modifying
originalMessage.
|
org.apache.hadoop.io.NullWritable |
createInitialMessage()
Get the initial message.
|
public void combine(org.apache.hadoop.io.WritableComparable vertexId, org.apache.hadoop.io.NullWritable null1, org.apache.hadoop.io.NullWritable null2)
MessageCombiner
combine
in interface MessageCombiner<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.NullWritable>
vertexId
- Index of the vertex getting these messagesnull1
- The first message which we want to combine;
put the result of combining in this messagenull2
- The second message which we want to combine
(object may be reused - do not reference it or its
member objects)public org.apache.hadoop.io.NullWritable createInitialMessage()
MessageCombiner
createInitialMessage
in interface MessageCombiner<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.NullWritable>
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.