protected static class MultiTableOutputFormat.MultiTableRecordWriter
extends <any>
Constructor and Description |
---|
MultiTableRecordWriter(Configuration conf,
boolean useWriteAheadLogging) |
Modifier and Type | Method and Description |
---|---|
void |
close(TaskAttemptContext context) |
void |
write(ImmutableBytesWritable tableName,
Mutation action)
Writes an action (Put or Delete) to the specified table.
|
public MultiTableRecordWriter(Configuration conf, boolean useWriteAheadLogging)
conf
- HBaseConfiguration to useduseWriteAheadLogging
- whether to use write ahead logging. This can be turned off (
false) to improve performance when bulk loading data.public void close(TaskAttemptContext context) throws java.io.IOException
java.io.IOException
public void write(ImmutableBytesWritable tableName, Mutation action) throws java.io.IOException
tableName
- the table being updated.action
- the update, either a put or a delete.java.lang.IllegalArgumentException
- if the action is not a put or a delete.java.io.IOException