public class TableOutputFormat
extends <any>
Modifier and Type | Class and Description |
---|---|
protected static class |
TableOutputFormat.TableRecordWriter
Convert Reduce output (key, value) to (HStoreKey, KeyedDataArrayWritable)
and write to an HBase table.
|
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
OUTPUT_TABLE
JobConf parameter that specifies the output table
|
Constructor and Description |
---|
TableOutputFormat() |
Modifier and Type | Method and Description |
---|---|
void |
checkOutputSpecs(FileSystem ignored,
JobConf job) |
RecordWriter |
getRecordWriter(FileSystem ignored,
JobConf job,
java.lang.String name,
Progressable progress)
Creates a new record writer.
|
public static final java.lang.String OUTPUT_TABLE
public RecordWriter getRecordWriter(FileSystem ignored, JobConf job, java.lang.String name, Progressable progress) throws java.io.IOException
RecordWriter
per job but in HBase, it is more natural if we give you a new
RecordWriter per call of this method. You must close the returned RecordWriter when done.
Failure to do so will drop writes.ignored
- Ignored filesystemjob
- Current JobConfname
- Name of the jobprogress
- java.io.IOException
- When creating the writer fails.public void checkOutputSpecs(FileSystem ignored, JobConf job) throws FileAlreadyExistsException, InvalidJobConfException, java.io.IOException
FileAlreadyExistsException
InvalidJobConfException
java.io.IOException