org.kepler.hadoop.io.output

Class TokenOutputFormat.TokenOutputCommitter

java.lang.Object

org.apache.hadoop.mapreduce.OutputCommitter

org.kepler.hadoop.io.output.TokenOutputFormat.TokenOutputCommitter

Enclosing class:

TokenOutputFormat

public static class TokenOutputFormat.TokenOutputCommitter
extends org.apache.hadoop.mapreduce.OutputCommitter

Constructor Summary

Constructors

Constructor and Description
TokenOutputCommitter()

Method Summary

Modifier and Type	Method and Description
void	abortTask(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext)
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, cleanupJob, commitJob, isRecoverySupported, recoverTask

Methods inherited from class java.lang.Object

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

Constructor Detail

TokenOutputCommitter

public TokenOutputCommitter()

Method Detail

needsTaskCommit

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

Specified by:

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

Throws:

java.io.IOException

commitTask

public void commitTask(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext)
                throws java.io.IOException

Specified by:

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

Throws:

java.io.IOException

abortTask

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

Specified by:

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

Throws:

java.io.IOException

setupJob

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

Specified by:

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

Throws:

java.io.IOException

setupTask

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

Specified by:

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

Throws:

java.io.IOException