Class TestTableMapReduce.ProcessContentsMapper

java.lang.Object
org.apache.hadoop.mapred.MapReduceBase
org.apache.hadoop.hbase.mapred.TestTableMapReduce.ProcessContentsMapper
All Implemented Interfaces:
Closeable, AutoCloseable, org.apache.hadoop.hbase.mapred.TableMap<org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Put>, org.apache.hadoop.io.Closeable, org.apache.hadoop.mapred.JobConfigurable, org.apache.hadoop.mapred.Mapper<org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Result,org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Put>
Enclosing class:
TestTableMapReduce

static class TestTableMapReduce.ProcessContentsMapper extends org.apache.hadoop.mapred.MapReduceBase implements org.apache.hadoop.hbase.mapred.TableMap<org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Put>
Pass the given key and processed record reduce
  • Constructor Summary

    Constructors
    Constructor
    Description
     
  • Method Summary

    Modifier and Type
    Method
    Description
    void
    map(org.apache.hadoop.hbase.io.ImmutableBytesWritable key, org.apache.hadoop.hbase.client.Result value, org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Put> output, org.apache.hadoop.mapred.Reporter reporter)
    Pass the key, and reversed value to reduce

    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 java.io.Closeable

    close

    Methods inherited from interface org.apache.hadoop.mapred.JobConfigurable

    configure
  • Constructor Details

  • Method Details

    • map

      public void map(org.apache.hadoop.hbase.io.ImmutableBytesWritable key, org.apache.hadoop.hbase.client.Result value, org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Put> output, org.apache.hadoop.mapred.Reporter reporter) throws IOException
      Pass the key, and reversed value to reduce
      Specified by:
      map in interface org.apache.hadoop.mapred.Mapper<org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Result,org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Put>
      Throws:
      IOException