@InterfaceAudience.Public
@InterfaceStability.Stable
public class TableOutputCommitter
extends org.apache.hadoop.mapreduce.OutputCommitter
Constructor and Description |
---|
TableOutputCommitter() |
Modifier and Type | Method and Description |
---|---|
void |
abortTask(org.apache.hadoop.mapreduce.TaskAttemptContext arg0) |
void |
cleanupJob(org.apache.hadoop.mapreduce.JobContext arg0) |
void |
commitTask(org.apache.hadoop.mapreduce.TaskAttemptContext arg0) |
boolean |
isRecoverySupported() |
boolean |
needsTaskCommit(org.apache.hadoop.mapreduce.TaskAttemptContext arg0) |
void |
recoverTask(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext) |
void |
setupJob(org.apache.hadoop.mapreduce.JobContext arg0) |
void |
setupTask(org.apache.hadoop.mapreduce.TaskAttemptContext arg0) |
public void abortTask(org.apache.hadoop.mapreduce.TaskAttemptContext arg0) throws IOException
abortTask
in class org.apache.hadoop.mapreduce.OutputCommitter
IOException
public void cleanupJob(org.apache.hadoop.mapreduce.JobContext arg0) throws IOException
cleanupJob
in class org.apache.hadoop.mapreduce.OutputCommitter
IOException
public void commitTask(org.apache.hadoop.mapreduce.TaskAttemptContext arg0) throws IOException
commitTask
in class org.apache.hadoop.mapreduce.OutputCommitter
IOException
public boolean needsTaskCommit(org.apache.hadoop.mapreduce.TaskAttemptContext arg0) throws IOException
needsTaskCommit
in class org.apache.hadoop.mapreduce.OutputCommitter
IOException
public void setupJob(org.apache.hadoop.mapreduce.JobContext arg0) throws IOException
setupJob
in class org.apache.hadoop.mapreduce.OutputCommitter
IOException
public void setupTask(org.apache.hadoop.mapreduce.TaskAttemptContext arg0) throws IOException
setupTask
in class org.apache.hadoop.mapreduce.OutputCommitter
IOException
public boolean isRecoverySupported()
isRecoverySupported
in class org.apache.hadoop.mapreduce.OutputCommitter
public void recoverTask(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext) throws IOException
recoverTask
in class org.apache.hadoop.mapreduce.OutputCommitter
IOException
Copyright © 2007–2016 The Apache Software Foundation. All rights reserved.