org.apache.hadoop.hbase.test

Class IntegrationTestLoadAndVerify.LoadMapper

java.lang.Object

<any>

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

Direct Known Subclasses:

IntegrationTestWithCellVisibilityLoadAndVerify.LoadWithCellVisibilityMapper

Enclosing class:

IntegrationTestLoadAndVerify

public static class IntegrationTestLoadAndVerify.LoadMapper
extends <any>

Field Summary

Fields

Modifier and Type	Field and Description
protected Configuration	conf
protected Connection	connection
protected BufferedMutator	mutator
protected int	numBackReferencesPerRow
protected Random	rand
protected long	recordsToWrite
protected Counter	refsWritten
protected Counter	rowsWritten
protected String	shortTaskId

Constructor Summary

Constructors

Constructor and Description
LoadMapper()

Method Summary

Modifier and Type	Method and Description
void	cleanup(Context context)
protected void	map(NullWritable key, NullWritable value, Context context)
void	setup(Context context)

Methods inherited from class java.lang.Object

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

Field Detail

recordsToWrite

protected long recordsToWrite

connection

protected Connection connection

mutator

protected BufferedMutator mutator

conf

protected Configuration conf

numBackReferencesPerRow

protected int numBackReferencesPerRow

shortTaskId

protected String shortTaskId

rand

protected Random rand

rowsWritten

protected Counter rowsWritten

refsWritten

protected Counter refsWritten

Constructor Detail

LoadMapper

public LoadMapper()

Method Detail

setup

public void setup(Context context)
           throws IOException

Throws:

IOException

cleanup

public void cleanup(Context context)
             throws IOException

Throws:

IOException

map

protected void map(NullWritable key,
                   NullWritable value,
                   Context context)
            throws IOException,
                   InterruptedException

Throws:

IOException

InterruptedException