oracle.spatial.hadoop.vector.join.mapreduce

Class JoinOutputCommitter

java.lang.Object

FileOutputCommitter

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

oracle.spatial.hadoop.vector.join.mapreduce.JoinOutputCommitter

public class JoinOutputCommitter
extends WrapperOutputCommitter

Cleans and commits the data output by the different JoinReducer instances.

Author:

hsaucedo

Constructor Summary

Constructors

Constructor and Description
JoinOutputCommitter(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

Constructor Detail

JoinOutputCommitter

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