org.apache.gora.mapreduce

Class NullOutputCommitter

java.lang.Object

org.apache.hadoop.mapreduce.OutputCommitter

org.apache.gora.mapreduce.NullOutputCommitter

public class NullOutputCommitter
extends org.apache.hadoop.mapreduce.OutputCommitter

An OutputCommitter that does nothing.

Constructor Summary

Constructors

Constructor and Description
NullOutputCommitter()

Method Summary

Methods

Modifier and Type	Method and 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	needsTaskCommit(org.apache.hadoop.mapreduce.TaskAttemptContext arg0)
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, isRecoverySupported, isRecoverySupported, recoverTask

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 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