Class CqlBulkOutputFormat.NullOutputCommitter

  • Enclosing class:
    CqlBulkOutputFormat

    public static class CqlBulkOutputFormat.NullOutputCommitter
    extends org.apache.hadoop.mapreduce.OutputCommitter
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void abortTask​(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext)  
      void cleanupJob​(org.apache.hadoop.mapreduce.JobContext jobContext)  
      void commitTask​(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext)  
      boolean needsTaskCommit​(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext)  
      void setupJob​(org.apache.hadoop.mapreduce.JobContext jobContext)  
      void setupTask​(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext)  
      • Methods inherited from class org.apache.hadoop.mapreduce.OutputCommitter

        abortJob, commitJob
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • NullOutputCommitter

        public NullOutputCommitter()
    • Method Detail

      • abortTask

        public void abortTask​(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext)
        Specified by:
        abortTask in class org.apache.hadoop.mapreduce.OutputCommitter
      • cleanupJob

        public void cleanupJob​(org.apache.hadoop.mapreduce.JobContext jobContext)
        Overrides:
        cleanupJob in class org.apache.hadoop.mapreduce.OutputCommitter
      • commitTask

        public void commitTask​(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext)
        Specified by:
        commitTask in class org.apache.hadoop.mapreduce.OutputCommitter
      • needsTaskCommit

        public boolean needsTaskCommit​(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext)
        Specified by:
        needsTaskCommit in class org.apache.hadoop.mapreduce.OutputCommitter
      • setupJob

        public void setupJob​(org.apache.hadoop.mapreduce.JobContext jobContext)
        Specified by:
        setupJob in class org.apache.hadoop.mapreduce.OutputCommitter
      • setupTask

        public void setupTask​(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext)
        Specified by:
        setupTask in class org.apache.hadoop.mapreduce.OutputCommitter