oracle.spatial.hadoop.vector.mapreduce.output

Class MergeFileOutputCommiter

java.lang.Object

FileOutputCommitter

oracle.spatial.hadoop.vector.mapreduce.output.WrapperOutputCommitter

oracle.spatial.hadoop.vector.mapreduce.output.MergeFileOutputCommiter

public class MergeFileOutputCommiter
extends WrapperOutputCommitter

Merges multiple part files into one single file

Author:

hsaucedo

Field Summary

Fields

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 Summary

Constructors

Constructor and Description
MergeFileOutputCommiter(OutputCommitter outCom, JobContext context)

Method Summary

Modifier and Type	Method and Description
void	commitJob(JobContext context)

Methods inherited from class oracle.spatial.hadoop.vector.mapreduce.output.WrapperOutputCommitter

abortJob, abortTask, abortTask, cleanupJob, commitTask, commitTask, getCommittedTaskPath, getJobAttemptPath, getTaskAttemptPath, getWorkPath, isRecoverySupported, isRecoverySupported, needsTaskCommit, needsTaskCommit, recoverTask, setupJob, setupTask

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

CONF_REMOVE_PART_FILES

public static final java.lang.String CONF_REMOVE_PART_FILES

Job configuration: boolean value that specifies whether the part files are removed or not.

See Also:

Constant Field Values

CONF_RESULT_FILE_NAME

public static final java.lang.String CONF_RESULT_FILE_NAME

Job configuration: the name of the resulting merged file

See Also:

Constant Field Values

Constructor Detail

MergeFileOutputCommiter

public MergeFileOutputCommiter(OutputCommitter outCom,
                               JobContext context)
                        throws java.io.IOException

Throws:

java.io.IOException

Method Detail

commitJob

public void commitJob(JobContext context)
               throws java.io.IOException

Overrides:

commitJob in class WrapperOutputCommitter

Throws:

java.io.IOException