Package org.apache.hadoop.hbase.mapreduce

Class TestHFileOutputFormat2.RandomPutGeneratingMapper

java.lang.Object

org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Put>

org.apache.hadoop.hbase.mapreduce.TestHFileOutputFormat2.RandomPutGeneratingMapper

Enclosing class:

TestHFileOutputFormat2

static class TestHFileOutputFormat2.RandomPutGeneratingMapper
extends org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Put>

Simple mapper that makes Put output.

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 static final String	KEYLEN_CONF
private static final int	KEYLEN_DEFAULT
private int	keyLength
private boolean	multiTableMapper
private static final byte[]	QUALIFIER
private org.apache.hadoop.hbase.TableName[]	tables
private static final String	VALLEN_CONF
private static final int	VALLEN_DEFAULT
private int	valLength

Constructor Summary

Constructors

Constructor	Description
RandomPutGeneratingMapper()

Method Summary

Modifier and Type	Method	Description
protected void	map(org.apache.hadoop.io.NullWritable n1, org.apache.hadoop.io.NullWritable n2, org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Put>.org.apache.hadoop.mapreduce.Mapper.Context context)
protected void	setup(org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Put>.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

keyLength

private int keyLength

KEYLEN_DEFAULT

private static final int KEYLEN_DEFAULT

See Also:

• Constant Field Values

KEYLEN_CONF

private static final String KEYLEN_CONF

See Also:

• Constant Field Values

valLength

private int valLength

VALLEN_DEFAULT

private static final int VALLEN_DEFAULT

See Also:

• Constant Field Values

VALLEN_CONF

private static final String VALLEN_CONF

See Also:

• Constant Field Values

QUALIFIER

private static final byte[] QUALIFIER

multiTableMapper

private boolean multiTableMapper

tables

private org.apache.hadoop.hbase.TableName[] tables

Constructor Details

RandomPutGeneratingMapper

RandomPutGeneratingMapper()

Method Details

setup

protected void setup(org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Put>.org.apache.hadoop.mapreduce.Mapper.Context context)
              throws IOException,
InterruptedException

Overrides:

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

Throws:

IOException

InterruptedException

map

protected void map(org.apache.hadoop.io.NullWritable n1,
 org.apache.hadoop.io.NullWritable n2,
 org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Put>.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.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Put>

Throws:

IOException

InterruptedException