public static class EsOutputFormat.EsOldAPIOutputCommitter extends OutputCommitter
| Constructor and Description |
|---|
EsOldAPIOutputCommitter() |
| Modifier and Type | Method and Description |
|---|---|
void |
abortTask(TaskAttemptContext taskContext) |
void |
cleanupJob(JobContext context)
Deprecated.
|
void |
commitTask(TaskAttemptContext taskContext) |
boolean |
needsTaskCommit(TaskAttemptContext taskContext) |
void |
setupJob(JobContext jobContext) |
void |
setupTask(TaskAttemptContext taskContext) |
abortJob, abortJob, abortTask, cleanupJob, commitJob, commitJob, commitTask, needsTaskCommit, setupJob, setupTaskpublic void setupJob(JobContext jobContext) throws java.io.IOException
setupJob in class OutputCommitterjava.io.IOExceptionpublic void setupTask(TaskAttemptContext taskContext) throws java.io.IOException
setupTask in class OutputCommitterjava.io.IOExceptionpublic boolean needsTaskCommit(TaskAttemptContext taskContext) throws java.io.IOException
needsTaskCommit in class OutputCommitterjava.io.IOExceptionpublic void commitTask(TaskAttemptContext taskContext) throws java.io.IOException
commitTask in class OutputCommitterjava.io.IOExceptionpublic void abortTask(TaskAttemptContext taskContext) throws java.io.IOException
abortTask in class OutputCommitterjava.io.IOException@Deprecated public void cleanupJob(JobContext context) throws java.io.IOException
cleanupJob in class OutputCommitterjava.io.IOException