Field Detail

• OUTPUT_TABLE

  public static final String OUTPUT_TABLE

  Job parameter that specifies the output table.

  See Also:

  Constant Field Values

• OUTPUT_CONF_PREFIX

  public static final String OUTPUT_CONF_PREFIX

  Prefix for configuration property overrides to apply in 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.

  See Also:

  Constant Field Values

• QUORUM_ADDRESS

  public static final String QUORUM_ADDRESS

  Optional job parameter to specify a peer cluster. Used specifying remote cluster when copying between hbase clusters (the source is picked up from hbase-site.xml).

  See Also:

  TableMapReduceUtil.initTableReducerJob(String, Class, org.apache.hadoop.mapreduce.Job, Class, String, String, String), Constant Field Values

• QUORUM_PORT

  public static final String QUORUM_PORT

  Optional job parameter to specify peer cluster's ZK client port

  See Also:

  Constant Field Values

• REGION_SERVER_CLASS

  public static final String REGION_SERVER_CLASS

  Optional specification of the rs class name of the peer cluster

  See Also:

  Constant Field Values

• REGION_SERVER_IMPL

  public static final String REGION_SERVER_IMPL

  Optional specification of the rs impl name of the peer cluster

  See Also:

  Constant Field Values

Constructor Detail

• TableOutputFormat

  public TableOutputFormat()

Method Detail

• getRecordWriter

  public org.apache.hadoop.mapreduce.RecordWriter<KEY,Mutation> getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                                                         throws IOException,
                                                                                InterruptedException

  Creates a new record writer.

  Specified by:

  getRecordWriter in class org.apache.hadoop.mapreduce.OutputFormat<KEY,Mutation>

  Parameters:

  context - The current task context.

  Returns:

  The newly created writer instance.

  Throws:

  IOException - When creating the writer fails.

  InterruptedException - When the jobs is cancelled.

• checkOutputSpecs

  public void checkOutputSpecs(org.apache.hadoop.mapreduce.JobContext context)
                        throws IOException,
                               InterruptedException

  Checks if the output table exists and is enabled.

  Specified by:

  checkOutputSpecs in class org.apache.hadoop.mapreduce.OutputFormat<KEY,Mutation>

  Parameters:

  context - The current context.

  Throws:

  IOException - When the check fails.

  InterruptedException - When the job is aborted.

  See Also:

  OutputFormat.checkOutputSpecs(JobContext)

• getOutputCommitter

  public org.apache.hadoop.mapreduce.OutputCommitter getOutputCommitter(org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                                                 throws IOException,
                                                                        InterruptedException

  Returns the output committer.

  Specified by:

  getOutputCommitter in class org.apache.hadoop.mapreduce.OutputFormat<KEY,Mutation>

  Parameters:

  context - The current context.

  Returns:

  The committer.

  Throws:

  IOException - When creating the committer fails.

  InterruptedException - When the job is aborted.

  See Also:

  OutputFormat.getOutputCommitter(TaskAttemptContext)

• getConf

  public org.apache.hadoop.conf.Configuration getConf()

  Specified by:

  getConf in interface org.apache.hadoop.conf.Configurable

• setConf

  public void setConf(org.apache.hadoop.conf.Configuration otherConf)

  Specified by:

  setConf in interface org.apache.hadoop.conf.Configurable