L
- Type of the left valueR
- Type of the right valuepublic class MaxPairReducer<L extends org.apache.hadoop.io.Writable,R extends org.apache.hadoop.io.WritableComparable> extends ReduceSameTypeOperation<PairWritable<L,R>>
Constructor and Description |
---|
MaxPairReducer()
Constructor used for deserialization only
|
MaxPairReducer(TypeOps<L> leftTypeOps,
TypeOps<R> rightTypeOps)
Constructor
|
Modifier and Type | Method and Description |
---|---|
PairWritable<L,R> |
createInitialValue()
Return new reduced value which is neutral to reduce operation.
|
void |
readFields(DataInput in) |
PairWritable<L,R> |
reduce(PairWritable<L,R> curValue,
PairWritable<L,R> valueToReduce)
Add a new value.
|
void |
write(DataOutput out) |
reduceMerge
public PairWritable<L,R> reduce(PairWritable<L,R> curValue, PairWritable<L,R> valueToReduce)
ReduceOperation
curValue
- Partial value into which to reduce and store the resultvalueToReduce
- Single value to be reducedpublic PairWritable<L,R> createInitialValue()
ReduceOperation
public void write(DataOutput out) throws IOException
IOException
public void readFields(DataInput in) throws IOException
IOException
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.