public class DocumentDBOutputCommitter
extends org.apache.hadoop.mapreduce.OutputCommitter
| Constructor and Description |
|---|
DocumentDBOutputCommitter() |
| Modifier and Type | Method and Description |
|---|---|
void |
abortTask(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext) |
void |
commitTask(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext) |
boolean |
needsTaskCommit(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext) |
void |
setupJob(org.apache.hadoop.mapreduce.JobContext jobContext) |
void |
setupTask(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext) |
public void abortTask(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext)
abortTask in class org.apache.hadoop.mapreduce.OutputCommitterpublic void commitTask(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext)
commitTask in class org.apache.hadoop.mapreduce.OutputCommitterpublic boolean needsTaskCommit(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext)
needsTaskCommit in class org.apache.hadoop.mapreduce.OutputCommitterpublic void setupJob(org.apache.hadoop.mapreduce.JobContext jobContext)
setupJob in class org.apache.hadoop.mapreduce.OutputCommitterpublic void setupTask(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext)
setupTask in class org.apache.hadoop.mapreduce.OutputCommitterCopyright © 2015. All rights reserved.