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