public static class TestTableInputFormatScanBase.ScanMapper extends TableMapper<ImmutableBytesWritable,ImmutableBytesWritable>
Constructor and Description |
---|
ScanMapper() |
Modifier and Type | Method and Description |
---|---|
void |
map(ImmutableBytesWritable key,
Result value,
Context context)
Pass the key and value to reduce.
|
public void map(ImmutableBytesWritable key, Result value, Context context) throws java.io.IOException, java.lang.InterruptedException
key
- The key, here "aaa", "aab" etc.value
- The value is the same as the key.context
- The task context.java.io.IOException
- When reading the rows fails.java.lang.InterruptedException