Package 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	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	Description
VerifyMapper()

Method Summary

Modifier and Type	Method	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<org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Result,org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.BytesWritable>.org.apache.hadoop.mapreduce.Mapper.Context context)
void	setup(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>.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 Details

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 Details

VerifyMapper

public VerifyMapper()

Method Details

setup

public void setup(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>.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<org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Result,org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.BytesWritable>.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)