Package org.apache.hadoop.hbase.mapred

Class TestTableMapReduceUtil.ClassificatorRowReduce

java.lang.Object
org.apache.hadoop.mapred.MapReduceBase
org.apache.hadoop.hbase.mapred.TestTableMapReduceUtil.ClassificatorRowReduce
All Implemented Interfaces:
Closeable, AutoCloseable, org.apache.hadoop.hbase.mapred.TableReduce<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.Reducer<org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Put,org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Put>
Enclosing class:
TestTableMapReduceUtil
static class TestTableMapReduceUtil.ClassificatorRowReduce extends org.apache.hadoop.mapred.MapReduceBase implements org.apache.hadoop.hbase.mapred.TableReduce<org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Put>

  • Constructor Summary

    Constructors
    Constructor
    Description
    ClassificatorRowReduce()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    reduce(org.apache.hadoop.hbase.io.ImmutableBytesWritable key, Iterator<org.apache.hadoop.hbase.client.Put> values, org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Put> output, org.apache.hadoop.mapred.Reporter reporter)
     
    private void
    throwAccertionError(String errorMessage)
     

    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

    • reduce

      public void reduce(org.apache.hadoop.hbase.io.ImmutableBytesWritable key, Iterator<org.apache.hadoop.hbase.client.Put> values, 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
      Specified by:
      reduce in interface org.apache.hadoop.mapred.Reducer<org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Put,org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Put>
      Throws:
      IOException

    • throwAccertionError

      private void throwAccertionError(String errorMessage) throws AssertionError
      Throws:
      AssertionError