public static class EsOutputFormat.EsOutputCommitter extends OutputCommitter
| Constructor and Description |
|---|
EsOutputCommitter() |
| Modifier and Type | Method and Description |
|---|---|
void |
abortTask(TaskAttemptContext taskContext) |
void |
cleanupJob(JobContext jobContext)
Deprecated.
|
void |
commitTask(TaskAttemptContext taskContext) |
boolean |
needsTaskCommit(TaskAttemptContext taskContext) |
void |
setupJob(JobContext jobContext) |
void |
setupTask(TaskAttemptContext taskContext) |
abortJob, commitJob, isCommitJobRepeatable, isRecoverySupported, isRecoverySupported, recoverTaskpublic void setupJob(JobContext jobContext) throws IOException
setupJob in class OutputCommitterIOException@Deprecated public void cleanupJob(JobContext jobContext) throws IOException
cleanupJob in class OutputCommitterIOExceptionpublic void setupTask(TaskAttemptContext taskContext) throws IOException
setupTask in class OutputCommitterIOExceptionpublic boolean needsTaskCommit(TaskAttemptContext taskContext) throws IOException
needsTaskCommit in class OutputCommitterIOExceptionpublic void commitTask(TaskAttemptContext taskContext) throws IOException
commitTask in class OutputCommitterIOExceptionpublic void abortTask(TaskAttemptContext taskContext) throws IOException
abortTask in class OutputCommitterIOException