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 IOException
row
- The current table row key.value
- The columns.context
- The current context.IOException
- When something is broken with the data.protected void processKV(ImmutableBytesWritable key, Result result, Context context, Put put, Delete delete) throws IOException, InterruptedException
IOException
InterruptedException
protected void addPutToKv(Put put, Cell kv) throws IOException
IOException
public void setup(Context context)