org.apache.giraph.utils

Class DefaultOutputCommitter

java.lang.Object

org.apache.hadoop.mapreduce.OutputCommitter

org.apache.giraph.utils.DefaultOutputCommitter

public abstract class DefaultOutputCommitter
extends org.apache.hadoop.mapreduce.OutputCommitter

Output committer which has abstract commit method

Constructor Summary

Constructors

Constructor and Description
DefaultOutputCommitter()

Method Summary

Modifier and Type	Method and Description
void	abortTask(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext)
abstract void	commit(org.apache.hadoop.mapreduce.JobContext jobContext) For cleaning up the job's output after job completion.
void	commitJob(org.apache.hadoop.mapreduce.JobContext jobContext)
void	commitTask(org.apache.hadoop.mapreduce.TaskAttemptContext context)
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, cleanupJob, isRecoverySupported, isRecoverySupported, recoverTask

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultOutputCommitter

public DefaultOutputCommitter()

Method Detail

commit

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

For cleaning up the job's output after job completion. Note that this is invoked for jobs with final run state as JobStatus.State.SUCCEEDED

Parameters:

jobContext - Context of the job whose output is being written.

Throws:

IOException

setupJob

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

Specified by:

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

Throws:

IOException

setupTask

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

Specified by:

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

Throws:

IOException

commitJob

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

Overrides:

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

Throws:

IOException

needsTaskCommit

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

Specified by:

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

Throws:

IOException

commitTask

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

Specified by:

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

Throws:

IOException

abortTask

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

Specified by:

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

Throws:

IOException