Package org.apache.hadoop.hbase.mapreduce

Class HashTable.HashMapper

java.lang.Object

org.apache.hadoop.mapreduce.Mapper<ImmutableBytesWritable,Result,KEYOUT,VALUEOUT>

org.apache.hadoop.hbase.mapreduce.TableMapper<ImmutableBytesWritable,ImmutableBytesWritable>

org.apache.hadoop.hbase.mapreduce.HashTable.HashMapper

Enclosing class:

HashTable

public static class HashTable.HashMapper
extends TableMapper<ImmutableBytesWritable,ImmutableBytesWritable>

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 ImmutableBytesWritable	currentRow
private HashTable.ResultHasher	hasher
private long	targetBatchSize

Constructor Summary

Constructors

Constructor	Description
HashMapper()

Method Summary

Modifier and Type	Method	Description
protected void	cleanup(org.apache.hadoop.mapreduce.Mapper<ImmutableBytesWritable,Result,ImmutableBytesWritable,ImmutableBytesWritable>.org.apache.hadoop.mapreduce.Mapper.Context context)
protected void	map(ImmutableBytesWritable key, Result value, org.apache.hadoop.mapreduce.Mapper<ImmutableBytesWritable,Result,ImmutableBytesWritable,ImmutableBytesWritable>.org.apache.hadoop.mapreduce.Mapper.Context context)
protected void	setup(org.apache.hadoop.mapreduce.Mapper<ImmutableBytesWritable,Result,ImmutableBytesWritable,ImmutableBytesWritable>.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

hasher

private HashTable.ResultHasher hasher

targetBatchSize

private long targetBatchSize

currentRow

private ImmutableBytesWritable currentRow

Constructor Details

HashMapper

public HashMapper()

Method Details

setup

protected void setup(org.apache.hadoop.mapreduce.Mapper<ImmutableBytesWritable,Result,ImmutableBytesWritable,ImmutableBytesWritable>.org.apache.hadoop.mapreduce.Mapper.Context context)
              throws IOException,
InterruptedException

Overrides:

setup in class org.apache.hadoop.mapreduce.Mapper<ImmutableBytesWritable,Result,ImmutableBytesWritable,ImmutableBytesWritable>

Throws:

IOException

InterruptedException

map

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

Overrides:

map in class org.apache.hadoop.mapreduce.Mapper<ImmutableBytesWritable,Result,ImmutableBytesWritable,ImmutableBytesWritable>

Throws:

IOException

InterruptedException

cleanup

protected void cleanup(org.apache.hadoop.mapreduce.Mapper<ImmutableBytesWritable,Result,ImmutableBytesWritable,ImmutableBytesWritable>.org.apache.hadoop.mapreduce.Mapper.Context context)
                throws IOException,
InterruptedException

Overrides:

cleanup in class org.apache.hadoop.mapreduce.Mapper<ImmutableBytesWritable,Result,ImmutableBytesWritable,ImmutableBytesWritable>

Throws:

IOException

InterruptedException