org.apache.hadoop.hbase.mapreduce

Class TestHFileOutputFormat2.RandomKVGeneratingMapper

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.Cell>

org.apache.hadoop.hbase.mapreduce.TestHFileOutputFormat2.RandomKVGeneratingMapper

Enclosing class:

TestHFileOutputFormat2

static class TestHFileOutputFormat2.RandomKVGeneratingMapper
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.Cell>

Simple mapper that makes KeyValue 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 and Description
private static String	KEYLEN_CONF
private static int	KEYLEN_DEFAULT
private int	keyLength
private boolean	multiTableMapper
private static byte[]	QUALIFIER
private org.apache.hadoop.hbase.TableName[]	tables
private static String	VALLEN_CONF
private static int	VALLEN_DEFAULT
private int	valLength

Constructor Summary

Constructors

Constructor and Description
RandomKVGeneratingMapper()

Method Summary

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

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 Detail

RandomKVGeneratingMapper

RandomKVGeneratingMapper()

Method Detail

setup

protected void setup(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.Cell>

Throws:

IOException

InterruptedException

map

protected void map(org.apache.hadoop.io.NullWritable n1,
                   org.apache.hadoop.io.NullWritable n2,
                   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.Cell>

Throws:

IOException

InterruptedException