org.apache.hadoop.hbase.mapred
Class IdentityTableReduce

java.lang.Object
  extended by org.apache.hadoop.mapred.MapReduceBase
      extended by org.apache.hadoop.hbase.mapred.TableReduce<ImmutableBytesWritable,BatchUpdate>
          extended by org.apache.hadoop.hbase.mapred.IdentityTableReduce
All Implemented Interfaces:
Closeable, org.apache.hadoop.mapred.JobConfigurable, org.apache.hadoop.mapred.Reducer<ImmutableBytesWritable,BatchUpdate,ImmutableBytesWritable,BatchUpdate>

public class IdentityTableReduce
extends TableReduce<ImmutableBytesWritable,BatchUpdate>

Write to table each key, record pair


Constructor Summary
IdentityTableReduce()
           
 
Method Summary
 void reduce(ImmutableBytesWritable key, Iterator<BatchUpdate> values, org.apache.hadoop.mapred.OutputCollector<ImmutableBytesWritable,BatchUpdate> output, org.apache.hadoop.mapred.Reporter reporter)
          No aggregation, output pairs of (key, record)
 
Methods inherited from class org.apache.hadoop.hbase.mapred.TableReduce
initJob
 
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
 
Methods inherited from interface java.io.Closeable
close
 

Constructor Detail

IdentityTableReduce

public IdentityTableReduce()
Method Detail

reduce

public void reduce(ImmutableBytesWritable key,
                   Iterator<BatchUpdate> values,
                   org.apache.hadoop.mapred.OutputCollector<ImmutableBytesWritable,BatchUpdate> output,
                   org.apache.hadoop.mapred.Reporter reporter)
            throws IOException
No aggregation, output pairs of (key, record)

Specified by:
reduce in interface org.apache.hadoop.mapred.Reducer<ImmutableBytesWritable,BatchUpdate,ImmutableBytesWritable,BatchUpdate>
Specified by:
reduce in class TableReduce<ImmutableBytesWritable,BatchUpdate>
Throws:
IOException
See Also:
TableReduce.reduce(org.apache.hadoop.io.WritableComparable, java.util.Iterator, org.apache.hadoop.mapred.OutputCollector, org.apache.hadoop.mapred.Reporter)


Copyright © 2008 The Apache Software Foundation