public static class Import.Importer extends TableMapper<ImmutableBytesWritable,Mutation>
Constructor and Description |
---|
Importer() |
Modifier and Type | Method and Description |
---|---|
protected void |
addPutToKv(Put put,
Cell kv) |
void |
map(ImmutableBytesWritable row,
Result value,
Context context) |
protected void |
processKV(ImmutableBytesWritable key,
Result result,
Context context,
Put put,
Delete delete) |
void |
setup(Context context) |
public void map(ImmutableBytesWritable row, Result value, Context context) throws java.io.IOException
row
- The current table row key.value
- The columns.context
- The current context.java.io.IOException
- When something is broken with the data.protected void processKV(ImmutableBytesWritable key, Result result, Context context, Put put, Delete delete) throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
protected void addPutToKv(Put put, Cell kv) throws java.io.IOException
java.io.IOException
public void setup(Context context)