protected class TableOutputFormat.TableRecordWriter
extends <any>
Constructor and Description |
---|
TableRecordWriter() |
Modifier and Type | Method and Description |
---|---|
void |
close(TaskAttemptContext context)
Closes the writer, in this case flush table commits.
|
void |
write(KEY key,
Mutation value)
Writes a key/value pair into the table.
|
public TableRecordWriter() throws java.io.IOException
java.io.IOException
public void close(TaskAttemptContext context) throws java.io.IOException
context
- The context.java.io.IOException
- When closing the writer fails.RecordWriter#close(TaskAttemptContext)
public void write(KEY key, Mutation value) throws java.io.IOException
key
- The key.value
- The value.java.io.IOException
- When writing fails.RecordWriter#write(Object, Object)