@InterfaceAudience.Public
@InterfaceStability.Evolving
public class KuduTableOutputCommitter
extends org.apache.hadoop.mapreduce.OutputCommitter
Constructor and Description |
---|
KuduTableOutputCommitter() |
Modifier and Type | Method and Description |
---|---|
void |
abortTask(org.apache.hadoop.mapreduce.TaskAttemptContext taskAttemptContext) |
void |
commitTask(org.apache.hadoop.mapreduce.TaskAttemptContext taskAttemptContext) |
boolean |
needsTaskCommit(org.apache.hadoop.mapreduce.TaskAttemptContext taskAttemptContext) |
void |
setupJob(org.apache.hadoop.mapreduce.JobContext jobContext) |
void |
setupTask(org.apache.hadoop.mapreduce.TaskAttemptContext taskAttemptContext) |
public void setupJob(org.apache.hadoop.mapreduce.JobContext jobContext) throws IOException
setupJob
in class org.apache.hadoop.mapreduce.OutputCommitter
IOException
public void setupTask(org.apache.hadoop.mapreduce.TaskAttemptContext taskAttemptContext) throws IOException
setupTask
in class org.apache.hadoop.mapreduce.OutputCommitter
IOException
public boolean needsTaskCommit(org.apache.hadoop.mapreduce.TaskAttemptContext taskAttemptContext) throws IOException
needsTaskCommit
in class org.apache.hadoop.mapreduce.OutputCommitter
IOException
public void commitTask(org.apache.hadoop.mapreduce.TaskAttemptContext taskAttemptContext) throws IOException
commitTask
in class org.apache.hadoop.mapreduce.OutputCommitter
IOException
public void abortTask(org.apache.hadoop.mapreduce.TaskAttemptContext taskAttemptContext) throws IOException
abortTask
in class org.apache.hadoop.mapreduce.OutputCommitter
IOException
Copyright © 2016 The Apache Software Foundation. All rights reserved.