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, commitJobpublic void setupJob(JobContext jobContext) throws java.io.IOException
setupJob in class OutputCommitterjava.io.IOException@Deprecated public void cleanupJob(JobContext jobContext) throws java.io.IOException
cleanupJob 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