Package org.apache.hadoop.hbase.mapreduce

Class TestTableMapReduce.ProcessContentsMapper

java.lang.Object
org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Result,KEYOUT,VALUEOUT>
org.apache.hadoop.hbase.mapreduce.TableMapper<org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Put>
org.apache.hadoop.hbase.mapreduce.TestTableMapReduce.ProcessContentsMapper
Enclosing class:
TestTableMapReduce
static class TestTableMapReduce.ProcessContentsMapper extends org.apache.hadoop.hbase.mapreduce.TableMapper<org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Put>
Pass the given key and processed record reduce

  • Nested Class Summary

    Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.Mapper

    org.apache.hadoop.mapreduce.Mapper.Context

  • Constructor Summary

    Constructors
    Constructor
    Description
    ProcessContentsMapper()
     

  • 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.mapreduce.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>.org.apache.hadoop.mapreduce.Mapper.Context context)
    Pass the key, and reversed value to reduce

    Methods inherited from class org.apache.hadoop.mapreduce.Mapper

    cleanup, run, setup

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • 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.mapreduce.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>.org.apache.hadoop.mapreduce.Mapper.Context context) throws IOException, InterruptedException
      Pass the key, and reversed value to reduce
      Overrides:
      map in class org.apache.hadoop.mapreduce.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
      InterruptedException