Constructor Detail

• TableOutputCommitter

  public TableOutputCommitter()

Method Detail

• abortTask

  public void abortTask(org.apache.hadoop.mapreduce.TaskAttemptContext arg0)
                 throws IOException

  Specified by:

  abortTask in class org.apache.hadoop.mapreduce.OutputCommitter

  Throws:

  IOException

• cleanupJob

  public void cleanupJob(org.apache.hadoop.mapreduce.JobContext arg0)
                  throws IOException

  Overrides:

  cleanupJob in class org.apache.hadoop.mapreduce.OutputCommitter

  Throws:

  IOException

• commitTask

  public void commitTask(org.apache.hadoop.mapreduce.TaskAttemptContext arg0)
                  throws IOException

  Specified by:

  commitTask in class org.apache.hadoop.mapreduce.OutputCommitter

  Throws:

  IOException

• needsTaskCommit

  public boolean needsTaskCommit(org.apache.hadoop.mapreduce.TaskAttemptContext arg0)
                          throws IOException

  Specified by:

  needsTaskCommit in class org.apache.hadoop.mapreduce.OutputCommitter

  Throws:

  IOException

• setupJob

  public void setupJob(org.apache.hadoop.mapreduce.JobContext arg0)
                throws IOException

  Specified by:

  setupJob in class org.apache.hadoop.mapreduce.OutputCommitter

  Throws:

  IOException

• setupTask

  public void setupTask(org.apache.hadoop.mapreduce.TaskAttemptContext arg0)
                 throws IOException

  Specified by:

  setupTask in class org.apache.hadoop.mapreduce.OutputCommitter

  Throws:

  IOException

• isRecoverySupported

  public boolean isRecoverySupported()

  Overrides:

  isRecoverySupported in class org.apache.hadoop.mapreduce.OutputCommitter

• recoverTask

  public void recoverTask(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext)
                   throws IOException

  Overrides:

  recoverTask in class org.apache.hadoop.mapreduce.OutputCommitter

  Throws:

  IOException