public static class Import.Importer extends TableMapper<ImmutableBytesWritable,Mutation>
Modifier and Type | Field and Description |
---|---|
private Map<byte[],byte[]> |
cfRenameMap |
private List<UUID> |
clusterIds |
private Durability |
durability |
private Filter |
filter |
Constructor and Description |
---|
Importer() |
Modifier and Type | Method and Description |
---|---|
protected void |
addPutToKv(Put put,
Cell kv) |
void |
map(ImmutableBytesWritable row,
Result value,
org.apache.hadoop.mapreduce.Mapper.Context context) |
protected void |
processKV(ImmutableBytesWritable key,
Result result,
org.apache.hadoop.mapreduce.Mapper.Context context,
Put put,
Delete delete) |
void |
setup(org.apache.hadoop.mapreduce.Mapper.Context context) |
private void |
writeResult(ImmutableBytesWritable key,
Result result,
org.apache.hadoop.mapreduce.Mapper.Context context) |
private Map<byte[],byte[]> cfRenameMap
private List<UUID> clusterIds
private Durability durability
public Importer()
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,Mutation>
row
- The current table row key.value
- The columns.context
- The current context.IOException
- When something is broken with the data.private void writeResult(ImmutableBytesWritable key, Result result, org.apache.hadoop.mapreduce.Mapper.Context context) throws IOException, InterruptedException
IOException
InterruptedException
protected void processKV(ImmutableBytesWritable key, Result result, org.apache.hadoop.mapreduce.Mapper.Context context, Put put, Delete delete) throws IOException, InterruptedException
IOException
InterruptedException
protected void addPutToKv(Put put, Cell kv) throws IOException
IOException
public void setup(org.apache.hadoop.mapreduce.Mapper.Context context)
setup
in class org.apache.hadoop.mapreduce.Mapper<ImmutableBytesWritable,Result,ImmutableBytesWritable,Mutation>
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.