| Interface | Description |
|---|---|
| MessageCombiner<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable> |
Abstract class to extend for combining messages sent to the same vertex.
|
| Class | Description |
|---|---|
| DoubleSumMessageCombiner | Deprecated |
| FloatSumMessageCombiner | Deprecated |
| MaxMessageCombiner<M extends org.apache.hadoop.io.WritableComparable> |
Message combiner which calculates max of all messages.
|
| MinimumDoubleMessageCombiner |
MessageCombiner which finds the minimum of
DoubleWritable. |
| MinimumIntMessageCombiner |
MessageCombiner that finds the minimum IntWritable |
| MinMessageCombiner<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable> |
Keeps only the message with minimum value.
|
| NullMessageCombiner |
Keeps only one NullMessage.
|
| SimpleSumMessageCombiner | Deprecated |
| SumMessageCombiner<M extends org.apache.hadoop.io.Writable> |
Message combiner which sums all messages.
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.