public class LegacyBridgeOutputCommitter
extends org.apache.hadoop.mapred.OutputCommitter
OutputCommitter (old API)
and StageOutputFormat.getOutputCommitter(org.apache.hadoop.mapreduce.TaskAttemptContext)
.Constructor and Description |
---|
LegacyBridgeOutputCommitter() |
Modifier and Type | Method and Description |
---|---|
void |
abortJob(org.apache.hadoop.mapred.JobContext jobContext,
int status) |
void |
abortTask(org.apache.hadoop.mapred.TaskAttemptContext taskContext) |
void |
cleanupJob(org.apache.hadoop.mapred.JobContext jobContext) |
void |
commitJob(org.apache.hadoop.mapred.JobContext jobContext) |
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 void setupJob(org.apache.hadoop.mapred.JobContext jobContext) throws IOException
setupJob
in class org.apache.hadoop.mapred.OutputCommitter
IOException
public void abortJob(org.apache.hadoop.mapred.JobContext jobContext, int status) throws IOException
abortJob
in class org.apache.hadoop.mapred.OutputCommitter
IOException
public void cleanupJob(org.apache.hadoop.mapred.JobContext jobContext) throws IOException
cleanupJob
in class org.apache.hadoop.mapred.OutputCommitter
IOException
public void commitJob(org.apache.hadoop.mapred.JobContext jobContext) throws IOException
commitJob
in class org.apache.hadoop.mapred.OutputCommitter
IOException
public void setupTask(org.apache.hadoop.mapred.TaskAttemptContext taskContext) throws IOException
setupTask
in class org.apache.hadoop.mapred.OutputCommitter
IOException
public boolean needsTaskCommit(org.apache.hadoop.mapred.TaskAttemptContext taskContext) throws IOException
needsTaskCommit
in class org.apache.hadoop.mapred.OutputCommitter
IOException
public void commitTask(org.apache.hadoop.mapred.TaskAttemptContext taskContext) throws IOException
commitTask
in class org.apache.hadoop.mapred.OutputCommitter
IOException
public void abortTask(org.apache.hadoop.mapred.TaskAttemptContext taskContext) throws IOException
abortTask
in class org.apache.hadoop.mapred.OutputCommitter
IOException
Copyright © 2011–2019 Asakusa Framework Team. All rights reserved.