public OutputCommitter getOutputCommitter()

in src/main/java/com/hadoop/mapreduce/LzoIndexOutputFormat.java [27:39]

• 13 lines of code
• 1 McCabe index (conditional complexity)

  public OutputCommitter getOutputCommitter(TaskAttemptContext taskAttemptContext)
      throws IOException, InterruptedException {
    return new OutputCommitter() {
      @Override public void setupJob(JobContext jobContext) throws IOException {}
      @Override public void cleanupJob(JobContext jobContext) throws IOException {}
      @Override public void setupTask(TaskAttemptContext taskAttemptContext) throws IOException {}
      @Override public void commitTask(TaskAttemptContext taskAttemptContext) throws IOException {}
      @Override public void abortTask(TaskAttemptContext taskAttemptContext) throws IOException {}
      @Override public boolean needsTaskCommit(TaskAttemptContext taskAttemptContext) throws IOException {
        return false;
      }
    };
  }