public class TableOutputFormat<KEY>
extends <any>
Put
or a
Delete
instance.Modifier and Type | Class and Description |
---|---|
protected class |
TableOutputFormat.TableRecordWriter
Writes the reducer output to an HBase table.
|
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
OUTPUT_CONF_PREFIX
Prefix for configuration property overrides to apply in
setConf(Configuration) . |
static java.lang.String |
OUTPUT_TABLE
Job parameter that specifies the output table.
|
static java.lang.String |
QUORUM_ADDRESS
Optional job parameter to specify a peer cluster.
|
static java.lang.String |
QUORUM_PORT
Optional job parameter to specify peer cluster's ZK client port
|
static java.lang.String |
REGION_SERVER_CLASS
Optional specification of the rs class name of the peer cluster
|
static java.lang.String |
REGION_SERVER_IMPL
Optional specification of the rs impl name of the peer cluster
|
Constructor and Description |
---|
TableOutputFormat() |
Modifier and Type | Method and Description |
---|---|
void |
checkOutputSpecs(JobContext context)
Checks if the output table exists and is enabled.
|
Configuration |
getConf() |
OutputCommitter |
getOutputCommitter(TaskAttemptContext context)
Returns the output committer.
|
<any> |
getRecordWriter(TaskAttemptContext context)
Creates a new record writer.
|
void |
setConf(Configuration otherConf) |
public static final java.lang.String OUTPUT_TABLE
public static final java.lang.String OUTPUT_CONF_PREFIX
setConf(Configuration)
.
For keys matching this prefix, the prefix is stripped, and the value is set in the
configuration with the resulting key, ie. the entry "hbase.mapred.output.key1 = value1"
would be set in the configuration as "key1 = value1". Use this to set properties
which should only be applied to the TableOutputFormat
configuration and not the
input configuration.public static final java.lang.String QUORUM_ADDRESS
hbase-site.xml
).TableMapReduceUtil#initTableReducerJob(String, Class, org.apache.hadoop.mapreduce.Job, Class, String, String, String)
,
Constant Field Valuespublic static final java.lang.String QUORUM_PORT
public static final java.lang.String REGION_SERVER_CLASS
public static final java.lang.String REGION_SERVER_IMPL
public <any> getRecordWriter(TaskAttemptContext context) throws java.io.IOException, java.lang.InterruptedException
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.context
- The current task context.java.io.IOException
- When creating the writer fails.java.lang.InterruptedException
- When the jobs is cancelled.public void checkOutputSpecs(JobContext context) throws java.io.IOException, java.lang.InterruptedException
context
- The current context.java.io.IOException
- When the check fails.java.lang.InterruptedException
- When the job is aborted.OutputFormat#checkOutputSpecs(JobContext)
public OutputCommitter getOutputCommitter(TaskAttemptContext context) throws java.io.IOException, java.lang.InterruptedException
context
- The current context.java.io.IOException
- When creating the committer fails.java.lang.InterruptedException
- When the job is aborted.OutputFormat#getOutputCommitter(TaskAttemptContext)
public Configuration getConf()
public void setConf(Configuration otherConf)