org.apache.hadoop.tools.mapred
Class CopyCommitter

java.lang.Object
  org.apache.hadoop.mapreduce.OutputCommitter
      org.apache.hadoop.mapreduce.lib.output.FileOutputCommitter
          org.apache.hadoop.tools.mapred.CopyCommitter

public class CopyCommitter
extends org.apache.hadoop.mapreduce.lib.output.FileOutputCommitter

Field Summary

Fields inherited from class org.apache.hadoop.mapreduce.lib.output.FileOutputCommitter

SUCCEEDED_FILE_NAME, TEMP_DIR_NAME

Constructor Summary

CopyCommitter(org.apache.hadoop.fs.Path outputPath, org.apache.hadoop.mapreduce.TaskAttemptContext context)
Create a output committer

Method Summary

void	abortJob(org.apache.hadoop.mapreduce.JobContext jobContext, org.apache.hadoop.mapreduce.JobStatus.State state)
void	commitJob(org.apache.hadoop.mapreduce.JobContext jobContext)

Methods inherited from class org.apache.hadoop.mapreduce.lib.output.FileOutputCommitter

abortTask, cleanupJob, commitTask, getWorkPath, needsTaskCommit, setupJob, setupTask

Methods inherited from class java.lang.Object

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

Constructor Detail

CopyCommitter

public CopyCommitter(org.apache.hadoop.fs.Path outputPath,
                     org.apache.hadoop.mapreduce.TaskAttemptContext context)
              throws IOException

Create a output committer

Parameters:

outputPath - the job's output path

context - the task's context

Throws:

IOException - - Exception if any

Method Detail

commitJob

public void commitJob(org.apache.hadoop.mapreduce.JobContext jobContext)
               throws IOException

Overrides:

commitJob in class org.apache.hadoop.mapreduce.lib.output.FileOutputCommitter

Throws:

IOException

abortJob

public void abortJob(org.apache.hadoop.mapreduce.JobContext jobContext,
                     org.apache.hadoop.mapreduce.JobStatus.State state)
              throws IOException

Overrides:

abortJob in class org.apache.hadoop.mapreduce.lib.output.FileOutputCommitter

Throws:

IOException