public class MergeFileOutputCommiter extends WrapperOutputCommitter
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
CONF_REMOVE_PART_FILES
Job configuration: boolean value that specifies whether the part files are removed or not.
|
static java.lang.String |
CONF_RESULT_FILE_NAME
Job configuration: the name of the resulting merged file
|
Constructor and Description |
---|
MergeFileOutputCommiter(OutputCommitter outCom, JobContext context) |
Modifier and Type | Method and Description |
---|---|
void |
commitJob(JobContext context) |
abortJob, abortTask, abortTask, cleanupJob, commitTask, commitTask, getCommittedTaskPath, getJobAttemptPath, getTaskAttemptPath, getWorkPath, isRecoverySupported, isRecoverySupported, needsTaskCommit, needsTaskCommit, recoverTask, setupJob, setupTask
public static final java.lang.String CONF_REMOVE_PART_FILES
public static final java.lang.String CONF_RESULT_FILE_NAME
public MergeFileOutputCommiter(OutputCommitter outCom, JobContext context) throws java.io.IOException
java.io.IOException
public void commitJob(JobContext context) throws java.io.IOException
commitJob
in class WrapperOutputCommitter
java.io.IOException
Copyright © 2017, 2019 Oracle and/or its affiliates. All Rights Reserved.