org.apache.hadoop.hbase.mapreduce

Class TableOutputCommitter

java.lang.Object

OutputCommitter

org.apache.hadoop.hbase.mapreduce.TableOutputCommitter

public class TableOutputCommitter
extends OutputCommitter

Small committer class that does not do anything.

Constructor Summary

Constructors

Constructor and Description
TableOutputCommitter()

Method Summary

Modifier and Type	Method and Description
void	abortTask(TaskAttemptContext arg0)
void	cleanupJob(JobContext arg0)
void	commitTask(TaskAttemptContext arg0)
boolean	isRecoverySupported()
boolean	needsTaskCommit(TaskAttemptContext arg0)
void	recoverTask(TaskAttemptContext taskContext)
void	setupJob(JobContext arg0)
void	setupTask(TaskAttemptContext arg0)

Methods inherited from class java.lang.Object

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

Constructor Detail

TableOutputCommitter

public TableOutputCommitter()

Method Detail

abortTask

public void abortTask(TaskAttemptContext arg0)
               throws java.io.IOException

Throws:

java.io.IOException

cleanupJob

public void cleanupJob(JobContext arg0)
                throws java.io.IOException

Throws:

java.io.IOException

commitTask

public void commitTask(TaskAttemptContext arg0)
                throws java.io.IOException

Throws:

java.io.IOException

needsTaskCommit

public boolean needsTaskCommit(TaskAttemptContext arg0)
                        throws java.io.IOException

Throws:

java.io.IOException

setupJob

public void setupJob(JobContext arg0)
              throws java.io.IOException

Throws:

java.io.IOException

setupTask

public void setupTask(TaskAttemptContext arg0)
               throws java.io.IOException

Throws:

java.io.IOException

isRecoverySupported

public boolean isRecoverySupported()

recoverTask

public void recoverTask(TaskAttemptContext taskContext)
                 throws java.io.IOException

Throws:

java.io.IOException