public static class MultiTableInputFormatTestBase.ScanMapper extends org.apache.hadoop.hbase.mapreduce.TableMapper<org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.io.ImmutableBytesWritable>
Constructor and Description |
---|
ScanMapper() |
Modifier and Type | Method and Description |
---|---|
void |
makeAssertions(org.apache.hadoop.hbase.io.ImmutableBytesWritable key,
org.apache.hadoop.hbase.client.Result value) |
void |
map(org.apache.hadoop.hbase.io.ImmutableBytesWritable key,
org.apache.hadoop.hbase.client.Result value,
org.apache.hadoop.mapreduce.Mapper.Context context)
Pass the key and value to reduce.
|
public ScanMapper()
public void map(org.apache.hadoop.hbase.io.ImmutableBytesWritable key, org.apache.hadoop.hbase.client.Result value, org.apache.hadoop.mapreduce.Mapper.Context context) throws IOException, InterruptedException
map
in class org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Result,org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.io.ImmutableBytesWritable>
key
- The key, here "aaa", "aab" etc.value
- The value is the same as the key.context
- The task context.IOException
- When reading the rows fails.InterruptedException
public void makeAssertions(org.apache.hadoop.hbase.io.ImmutableBytesWritable key, org.apache.hadoop.hbase.client.Result value) throws IOException
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.