|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.hadoop.mapreduce.OutputFormat<KEY,org.apache.hadoop.io.Writable>
org.apache.hadoop.hbase.mapreduce.TableOutputFormat<KEY>
KEY
- The type of the key. Ignored in this class.public class TableOutputFormat<KEY>
Convert Map/Reduce output and write it to an HBase table. The KEY is ignored
while the output value must be either a Put
or a
Delete
instance.
Nested Class Summary | |
---|---|
protected static class |
TableOutputFormat.TableRecordWriter<KEY>
Writes the reducer output to an HBase table. |
Field Summary | |
---|---|
static String |
OUTPUT_TABLE
Job parameter that specifies the output table. |
static String |
QUORUM_ADDRESS
Optional job parameter to specify a peer cluster. |
static String |
REGION_SERVER_CLASS
Optional specification of the rs class name of the peer cluster |
static String |
REGION_SERVER_IMPL
Optional specification of the rs impl name of the peer cluster |
Constructor Summary | |
---|---|
TableOutputFormat()
|
Method Summary | |
---|---|
void |
checkOutputSpecs(org.apache.hadoop.mapreduce.JobContext context)
Checks if the output target exists. |
org.apache.hadoop.conf.Configuration |
getConf()
|
org.apache.hadoop.mapreduce.OutputCommitter |
getOutputCommitter(org.apache.hadoop.mapreduce.TaskAttemptContext context)
Returns the output committer. |
org.apache.hadoop.mapreduce.RecordWriter<KEY,org.apache.hadoop.io.Writable> |
getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context)
Creates a new record writer. |
void |
setConf(org.apache.hadoop.conf.Configuration otherConf)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final String OUTPUT_TABLE
public static final String QUORUM_ADDRESS
hbase-site.xml
).
TableMapReduceUtil.initTableReducerJob(String, Class, org.apache.hadoop.mapreduce.Job, Class, String, String, String)
,
Constant Field Valuespublic static final String REGION_SERVER_CLASS
public static final String REGION_SERVER_IMPL
Constructor Detail |
---|
public TableOutputFormat()
Method Detail |
---|
public org.apache.hadoop.mapreduce.RecordWriter<KEY,org.apache.hadoop.io.Writable> getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException, InterruptedException
getRecordWriter
in class org.apache.hadoop.mapreduce.OutputFormat<KEY,org.apache.hadoop.io.Writable>
context
- The current task context.
IOException
- When creating the writer fails.
InterruptedException
- When the jobs is cancelled.FileOutputFormat.getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext)
public void checkOutputSpecs(org.apache.hadoop.mapreduce.JobContext context) throws IOException, InterruptedException
checkOutputSpecs
in class org.apache.hadoop.mapreduce.OutputFormat<KEY,org.apache.hadoop.io.Writable>
context
- The current context.
IOException
- When the check fails.
InterruptedException
- When the job is aborted.OutputFormat.checkOutputSpecs(org.apache.hadoop.mapreduce.JobContext)
public org.apache.hadoop.mapreduce.OutputCommitter getOutputCommitter(org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException, InterruptedException
getOutputCommitter
in class org.apache.hadoop.mapreduce.OutputFormat<KEY,org.apache.hadoop.io.Writable>
context
- The current context.
IOException
- When creating the committer fails.
InterruptedException
- When the job is aborted.OutputFormat.getOutputCommitter(org.apache.hadoop.mapreduce.TaskAttemptContext)
public org.apache.hadoop.conf.Configuration getConf()
getConf
in interface org.apache.hadoop.conf.Configurable
public void setConf(org.apache.hadoop.conf.Configuration otherConf)
setConf
in interface org.apache.hadoop.conf.Configurable
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |