org.apache.hadoop.hbase.test

Class IntegrationTestWithCellVisibilityLoadAndVerify.VerifyMapper

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.io.BytesWritable,org.apache.hadoop.io.BytesWritable>

org.apache.hadoop.hbase.test.IntegrationTestWithCellVisibilityLoadAndVerify.VerifyMapper

Enclosing class:

IntegrationTestWithCellVisibilityLoadAndVerify

public static class IntegrationTestWithCellVisibilityLoadAndVerify.VerifyMapper
extends org.apache.hadoop.hbase.mapreduce.TableMapper<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.BytesWritable>

Nested Class Summary

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

org.apache.hadoop.mapreduce.Mapper.Context

Field Summary

Fields

Modifier and Type	Field and Description
private org.apache.hadoop.mapreduce.Counter	rowsExp1
private org.apache.hadoop.mapreduce.Counter	rowsExp2
private org.apache.hadoop.mapreduce.Counter	rowsExp3
private org.apache.hadoop.mapreduce.Counter	rowsExp4

Constructor Summary

Constructors

Constructor and Description
VerifyMapper()

Method Summary

Modifier and Type	Method and Description
private org.apache.hadoop.mapreduce.Counter	getCounter(byte[] row)
protected void	map(org.apache.hadoop.hbase.io.ImmutableBytesWritable key, org.apache.hadoop.hbase.client.Result value, org.apache.hadoop.mapreduce.Mapper.Context context)
void	setup(org.apache.hadoop.mapreduce.Mapper.Context context)

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

cleanup, run

Methods inherited from class java.lang.Object

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

Field Detail

rowsExp1

private org.apache.hadoop.mapreduce.Counter rowsExp1

rowsExp2

private org.apache.hadoop.mapreduce.Counter rowsExp2

rowsExp3

private org.apache.hadoop.mapreduce.Counter rowsExp3

rowsExp4

private org.apache.hadoop.mapreduce.Counter rowsExp4

Constructor Detail

VerifyMapper

public VerifyMapper()

Method Detail

setup

public void setup(org.apache.hadoop.mapreduce.Mapper.Context context)
           throws IOException

Overrides:

setup in class org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Result,org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.BytesWritable>

Throws:

IOException

map

protected void map(org.apache.hadoop.hbase.io.ImmutableBytesWritable key,
                   org.apache.hadoop.hbase.client.Result value,
                   org.apache.hadoop.mapreduce.Mapper.Context context)
            throws IOException,
                   InterruptedException

Overrides:

map in class org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Result,org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.BytesWritable>

Throws:

IOException

InterruptedException

getCounter

private org.apache.hadoop.mapreduce.Counter getCounter(byte[] row)