org.apache.hadoop.hbase.mapreduce

Class IntegrationTestBulkLoad.LinkedListCreationMapper

java.lang.Object

org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.KeyValue>

org.apache.hadoop.hbase.mapreduce.IntegrationTestBulkLoad.LinkedListCreationMapper

Enclosing class:

IntegrationTestBulkLoad

public static class IntegrationTestBulkLoad.LinkedListCreationMapper
extends org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.KeyValue>

Mapper that creates a linked list of KeyValues. Each map task generates one linked list. All lists start on row key 0L. All lists should be CHAIN_LENGTH long.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.Mapper

org.apache.hadoop.mapreduce.Mapper.Context

Constructor Summary

Constructors

Constructor and Description
LinkedListCreationMapper()

Method Summary

Modifier and Type	Method and Description
private long	getNextRow(long index, long chainLength) Returns a unique row id within this chain for this index
protected void	map(org.apache.hadoop.io.LongWritable key, org.apache.hadoop.io.LongWritable value, org.apache.hadoop.mapreduce.Mapper.Context context)

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

cleanup, run, setup

Methods inherited from class java.lang.Object

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

Constructor Detail

LinkedListCreationMapper

public LinkedListCreationMapper()

Method Detail

map

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

Overrides:

map in class org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.KeyValue>

Throws:

IOException

InterruptedException

getNextRow

private long getNextRow(long index,
                        long chainLength)

Returns a unique row id within this chain for this index