Package org.apache.hadoop.hbase.mapred
Class IdentityTableReduce
java.lang.Object
org.apache.hadoop.mapred.MapReduceBase
org.apache.hadoop.hbase.mapred.IdentityTableReduce
- All Implemented Interfaces:
Closeable
,AutoCloseable
,TableReduce<ImmutableBytesWritable,
,Put> org.apache.hadoop.io.Closeable
,org.apache.hadoop.mapred.JobConfigurable
,org.apache.hadoop.mapred.Reducer<ImmutableBytesWritable,
Put, ImmutableBytesWritable, Put>
@Public
public class IdentityTableReduce
extends org.apache.hadoop.mapred.MapReduceBase
implements TableReduce<ImmutableBytesWritable,Put>
Write to table each key, record pair
-
Field Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
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)Methods inherited from class org.apache.hadoop.mapred.MapReduceBase
close, configure
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.apache.hadoop.mapred.JobConfigurable
configure
-
Field Details
-
LOG
-
-
Constructor Details
-
IdentityTableReduce
public IdentityTableReduce()
-
-
Method Details
-
reduce
public void reduce(ImmutableBytesWritable key, Iterator<Put> values, org.apache.hadoop.mapred.OutputCollector<ImmutableBytesWritable, Put> output, org.apache.hadoop.mapred.Reporter reporter) throws IOExceptionNo aggregation, output pairs of (key, record)- Specified by:
reduce
in interfaceorg.apache.hadoop.mapred.Reducer<ImmutableBytesWritable,
Put, ImmutableBytesWritable, Put> - Throws:
IOException
-