I- Vertex id
M- Message data
public interface MessageCombiner<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>
vertexIndex- Index of the vertex getting these messages
originalMessage- The first message which we want to combine; put the result of combining in this message
messageToCombine- The second message which we want to combine (object may be reused - do not reference it or its member objects)
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.