@InterfaceAudience.Public @InterfaceStability.Stable 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 IOException
IOException
public void cleanupJob(JobContext arg0) throws IOException
IOException
public void commitTask(TaskAttemptContext arg0) throws IOException
IOException
public boolean needsTaskCommit(TaskAttemptContext arg0) throws IOException
IOException
public void setupJob(JobContext arg0) throws IOException
IOException
public void setupTask(TaskAttemptContext arg0) throws IOException
IOException
public boolean isRecoverySupported()
public void recoverTask(TaskAttemptContext taskContext) throws IOException
IOException