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