@InterfaceAudience.Public @InterfaceStability.Stable public class IdentityTableReduce extends org.apache.hadoop.mapred.MapReduceBase implements TableReduce<ImmutableBytesWritable,Put>
| Modifier and Type | Field and Description |
|---|---|
private static org.apache.commons.logging.Log |
LOG |
| Constructor and Description |
|---|
IdentityTableReduce() |
| Modifier and Type | Method and Description |
|---|---|
void |
reduce(ImmutableBytesWritable key,
Iterator<Put> values,
org.apache.hadoop.mapred.OutputCollector<ImmutableBytesWritable,Put> output,
org.apache.hadoop.mapred.Reporter reporter)
No aggregation, output pairs of (key, record)
|
public void reduce(ImmutableBytesWritable key, Iterator<Put> values, org.apache.hadoop.mapred.OutputCollector<ImmutableBytesWritable,Put> output, org.apache.hadoop.mapred.Reporter reporter) throws IOException
reduce in interface org.apache.hadoop.mapred.Reducer<ImmutableBytesWritable,Put,ImmutableBytesWritable,Put>key - values - output - reporter - IOExceptionCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.