Package org.apache.hadoop.hbase.mapreduce

Class TableOutputCommitter

java.lang.Object
org.apache.hadoop.mapreduce.OutputCommitter
org.apache.hadoop.hbase.mapreduce.TableOutputCommitter
@Public public class TableOutputCommitter extends org.apache.hadoop.mapreduce.OutputCommitter
Small committer class that does not do anything.

  • Constructor Summary

    Constructors
    Constructor
    Description
    TableOutputCommitter()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    abortTask(org.apache.hadoop.mapreduce.TaskAttemptContext arg0)
     
    void
    cleanupJob(org.apache.hadoop.mapreduce.JobContext arg0)
     
    void
    commitTask(org.apache.hadoop.mapreduce.TaskAttemptContext arg0)
     
    boolean
    isRecoverySupported()
     
    boolean
    needsTaskCommit(org.apache.hadoop.mapreduce.TaskAttemptContext arg0)
     
    void
    recoverTask(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext)
     
    void
    setupJob(org.apache.hadoop.mapreduce.JobContext arg0)
     
    void
    setupTask(org.apache.hadoop.mapreduce.TaskAttemptContext arg0)
     

    Methods inherited from class org.apache.hadoop.mapreduce.OutputCommitter

    abortJob, commitJob, isCommitJobRepeatable, isRecoverySupported

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

  • Method Details

    • 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