oracle.spatial.hadoop.vector.mapreduce.output

Class MultipleOutputMergeOutputCommitter

java.lang.Object

FileOutputCommitter

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

oracle.spatial.hadoop.vector.mapreduce.output.MultipleOutputMergeOutputCommitter

public class MultipleOutputMergeOutputCommitter
extends WrapperOutputCommitter

Merges the part files of multiple named outputs into one file for each named output

Author:

hsaucedo

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	CONFIG_NAMEDOUTPUT_TO_MERGEDNAME_RELATION Job configuration: a comma-separated list of assignments in the form namedOutput=finalMergedFileName

Constructor Summary

Constructors

Constructor and Description
MultipleOutputMergeOutputCommitter(OutputCommitter outCom, JobContext context)

Method Summary

Modifier and Type	Method and Description
void	commitJob(JobContext context)
static java.util.Map<java.lang.String,java.lang.String>	getNamedToMergedOutMap(Configuration conf)

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

CONFIG_NAMEDOUTPUT_TO_MERGEDNAME_RELATION

public static final java.lang.String CONFIG_NAMEDOUTPUT_TO_MERGEDNAME_RELATION

Job configuration: a comma-separated list of assignments in the form namedOutput=finalMergedFileName

See Also:

Constant Field Values

Constructor Detail

MultipleOutputMergeOutputCommitter

public MultipleOutputMergeOutputCommitter(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

getNamedToMergedOutMap

public static java.util.Map<java.lang.String,java.lang.String> getNamedToMergedOutMap(Configuration conf)