See: Description
Class | Description |
---|---|
SendMessagePiece<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M extends org.apache.hadoop.io.Writable> |
Piece that sends a message provided through messageProducer to given set of
neighbors, and passes them to messagesConsumer.
|
SendMessageWithCombinerPiece<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M extends org.apache.hadoop.io.Writable> |
Piece that sends a message provided through messageProducer to given set of
neighbors, uses a message combiner and passes them to messagesConsumer.
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.