public static class Import.KeyValueImporter extends TableMapper<ImmutableBytesWritable,KeyValue>
| Modifier and Type | Field and Description |
|---|---|
private Map<byte[],byte[]> |
cfRenameMap |
private Filter |
filter |
private static org.apache.commons.logging.Log |
LOG |
| Constructor and Description |
|---|
Import.KeyValueImporter() |
| Modifier and Type | Method and Description |
|---|---|
void |
map(ImmutableBytesWritable row,
Result value,
org.apache.hadoop.mapreduce.Mapper.Context context) |
void |
setup(org.apache.hadoop.mapreduce.Mapper.Context context) |
private Map<byte[],byte[]> cfRenameMap
private Filter filter
private static final org.apache.commons.logging.Log LOG
public void map(ImmutableBytesWritable row, Result value, org.apache.hadoop.mapreduce.Mapper.Context context) throws IOException
map in class org.apache.hadoop.mapreduce.Mapper<ImmutableBytesWritable,Result,ImmutableBytesWritable,KeyValue>row - The current table row key.value - The columns.context - The current context.IOException - When something is broken with the data.public void setup(org.apache.hadoop.mapreduce.Mapper.Context context)
setup in class org.apache.hadoop.mapreduce.Mapper<ImmutableBytesWritable,Result,ImmutableBytesWritable,KeyValue>Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.