public static class HashTable.HashMapper extends TableMapper<ImmutableBytesWritable,ImmutableBytesWritable>
| Modifier and Type | Field and Description |
|---|---|
private ImmutableBytesWritable |
currentRow |
private HashTable.ResultHasher |
hasher |
private long |
targetBatchSize |
| Constructor and Description |
|---|
HashTable.HashMapper() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
cleanup(org.apache.hadoop.mapreduce.Mapper.Context context) |
protected void |
map(ImmutableBytesWritable key,
Result value,
org.apache.hadoop.mapreduce.Mapper.Context context) |
protected void |
setup(org.apache.hadoop.mapreduce.Mapper.Context context) |
private HashTable.ResultHasher hasher
private long targetBatchSize
private ImmutableBytesWritable currentRow
protected void setup(org.apache.hadoop.mapreduce.Mapper.Context context)
throws IOException,
InterruptedException
setup in class org.apache.hadoop.mapreduce.Mapper<ImmutableBytesWritable,Result,ImmutableBytesWritable,ImmutableBytesWritable>IOExceptionInterruptedExceptionprotected void map(ImmutableBytesWritable key, Result value, org.apache.hadoop.mapreduce.Mapper.Context context) throws IOException, InterruptedException
map in class org.apache.hadoop.mapreduce.Mapper<ImmutableBytesWritable,Result,ImmutableBytesWritable,ImmutableBytesWritable>IOExceptionInterruptedExceptionprotected void cleanup(org.apache.hadoop.mapreduce.Mapper.Context context)
throws IOException,
InterruptedException
cleanup in class org.apache.hadoop.mapreduce.Mapper<ImmutableBytesWritable,Result,ImmutableBytesWritable,ImmutableBytesWritable>IOExceptionInterruptedExceptionCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.