Package org.apache.hadoop.hbase.test

Class IntegrationTestLoadAndVerify.LoadMapper

java.lang.Object

org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable>

org.apache.hadoop.hbase.test.IntegrationTestLoadAndVerify.LoadMapper

Direct Known Subclasses:

IntegrationTestWithCellVisibilityLoadAndVerify.LoadWithCellVisibilityMapper

Enclosing class:

IntegrationTestLoadAndVerify

public static class IntegrationTestLoadAndVerify.LoadMapper
extends org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable>

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
protected org.apache.hadoop.conf.Configuration	conf
protected org.apache.hadoop.hbase.client.Connection	connection
protected org.apache.hadoop.hbase.client.BufferedMutator	mutator
protected int	numBackReferencesPerRow
protected long	recordsToWrite
protected org.apache.hadoop.mapreduce.Counter	refsWritten
protected org.apache.hadoop.mapreduce.Counter	rowsWritten
protected String	shortTaskId

Constructor Summary

Constructors

Constructor	Description
LoadMapper()

Method Summary

Modifier and Type	Method	Description
void	cleanup(org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable>.org.apache.hadoop.mapreduce.Mapper.Context context)
protected void	map(org.apache.hadoop.io.NullWritable key, org.apache.hadoop.io.NullWritable value, org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable>.org.apache.hadoop.mapreduce.Mapper.Context context)
void	setup(org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable>.org.apache.hadoop.mapreduce.Mapper.Context context)

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

run

Methods inherited from class java.lang.Object

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

Field Details

recordsToWrite

protected long recordsToWrite

connection

protected org.apache.hadoop.hbase.client.Connection connection

mutator

protected org.apache.hadoop.hbase.client.BufferedMutator mutator

conf

protected org.apache.hadoop.conf.Configuration conf

numBackReferencesPerRow

protected int numBackReferencesPerRow

shortTaskId

protected String shortTaskId

rowsWritten

protected org.apache.hadoop.mapreduce.Counter rowsWritten

refsWritten

protected org.apache.hadoop.mapreduce.Counter refsWritten

Constructor Details

LoadMapper

public LoadMapper()

Method Details

setup

public void setup(org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable>.org.apache.hadoop.mapreduce.Mapper.Context context)
           throws IOException

Overrides:

setup in class org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable>

Throws:

IOException

cleanup

public void cleanup(org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable>.org.apache.hadoop.mapreduce.Mapper.Context context)
             throws IOException

Overrides:

cleanup in class org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable>

Throws:

IOException

map

protected void map(org.apache.hadoop.io.NullWritable key,
 org.apache.hadoop.io.NullWritable value,
 org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable>.org.apache.hadoop.mapreduce.Mapper.Context context)
            throws IOException,
InterruptedException

Overrides:

map in class org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable>

Throws:

IOException

InterruptedException