public class ImmutableOutputCommitter
extends org.apache.hadoop.mapreduce.OutputCommitter
Constructor and Description |
---|
ImmutableOutputCommitter() |
Modifier and Type | Method and Description |
---|---|
void |
abortTask(org.apache.hadoop.mapreduce.TaskAttemptContext context) |
void |
commitJob(org.apache.hadoop.mapreduce.JobContext jobContext) |
void |
commitTask(org.apache.hadoop.mapreduce.TaskAttemptContext context) |
boolean |
needsTaskCommit(org.apache.hadoop.mapreduce.TaskAttemptContext context) |
void |
setupJob(org.apache.hadoop.mapreduce.JobContext context) |
void |
setupTask(org.apache.hadoop.mapreduce.TaskAttemptContext context) |
public void abortTask(org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException
abortTask
in class org.apache.hadoop.mapreduce.OutputCommitter
IOException
public void commitTask(org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException
commitTask
in class org.apache.hadoop.mapreduce.OutputCommitter
IOException
public boolean needsTaskCommit(org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException
needsTaskCommit
in class org.apache.hadoop.mapreduce.OutputCommitter
IOException
public void setupJob(org.apache.hadoop.mapreduce.JobContext context) throws IOException
setupJob
in class org.apache.hadoop.mapreduce.OutputCommitter
IOException
public void setupTask(org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException
setupTask
in class org.apache.hadoop.mapreduce.OutputCommitter
IOException
public void commitJob(org.apache.hadoop.mapreduce.JobContext jobContext) throws IOException
commitJob
in class org.apache.hadoop.mapreduce.OutputCommitter
IOException
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.