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