public class ParquetOutputCommitter
extends org.apache.hadoop.mapreduce.lib.output.FileOutputCommitter
Constructor and Description |
---|
ParquetOutputCommitter(org.apache.hadoop.fs.Path outputPath,
org.apache.hadoop.mapreduce.TaskAttemptContext context) |
Modifier and Type | Method and Description |
---|---|
void |
commitJob(org.apache.hadoop.mapreduce.JobContext jobContext) |
abortJob, abortTask, abortTask, cleanupJob, commitTask, commitTask, getCommittedTaskPath, getCommittedTaskPath, getCommittedTaskPath, getJobAttemptPath, getJobAttemptPath, getJobAttemptPath, getTaskAttemptPath, getTaskAttemptPath, getWorkPath, isRecoverySupported, needsTaskCommit, needsTaskCommit, recoverTask, setupJob, setupTask
public ParquetOutputCommitter(org.apache.hadoop.fs.Path outputPath, org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException
IOException
public void commitJob(org.apache.hadoop.mapreduce.JobContext jobContext) throws IOException
commitJob
in class org.apache.hadoop.mapreduce.lib.output.FileOutputCommitter
IOException
Copyright © 2015. All rights reserved.