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.