public static class EsOutputFormat.EsOldAPIOutputCommitter extends OutputCommitter
| Constructor and Description |
|---|
EsOutputFormat.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 EsOutputFormat.EsOldAPIOutputCommitter()
public void setupJob(JobContext jobContext) throws IOException
setupJob 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@Deprecated public void cleanupJob(JobContext context) throws IOException
cleanupJob in class OutputCommitterIOException