public class TableOutputCommitter
extends OutputCommitter
Constructor and Description |
---|
TableOutputCommitter() |
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) |
public void abortTask(TaskAttemptContext arg0) throws java.io.IOException
java.io.IOException
public void cleanupJob(JobContext arg0) throws java.io.IOException
java.io.IOException
public void commitTask(TaskAttemptContext arg0) throws java.io.IOException
java.io.IOException
public boolean needsTaskCommit(TaskAttemptContext arg0) throws java.io.IOException
java.io.IOException
public void setupJob(JobContext arg0) throws java.io.IOException
java.io.IOException
public void setupTask(TaskAttemptContext arg0) throws java.io.IOException
java.io.IOException
public boolean isRecoverySupported()
public void recoverTask(TaskAttemptContext taskContext) throws java.io.IOException
java.io.IOException