oracle.spatial.hadoop.vector.join.mapreduce

Class JoinOutputCommitter

java.lang.Object

org.apache.hadoop.mapreduce.OutputCommitter

org.apache.hadoop.mapreduce.lib.output.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.

Field Summary

Fields inherited from class org.apache.hadoop.mapreduce.lib.output.FileOutputCommitter

PENDING_DIR_NAME, SUCCEEDED_FILE_NAME, SUCCESSFUL_JOB_OUTPUT_DIR_MARKER, TEMP_DIR_NAME

Constructor Summary

Constructors

Constructor and Description
JoinOutputCommitter(org.apache.hadoop.mapreduce.OutputCommitter outCom, org.apache.hadoop.mapreduce.JobContext context)

Method Summary

Modifier and Type	Method and Description
void	commitJob(org.apache.hadoop.mapreduce.JobContext context)

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

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

Methods inherited from class org.apache.hadoop.mapreduce.lib.output.FileOutputCommitter

getCommittedTaskPath, getJobAttemptPath, getTaskAttemptPath

Methods inherited from class java.lang.Object

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

Constructor Detail

JoinOutputCommitter

public JoinOutputCommitter(org.apache.hadoop.mapreduce.OutputCommitter outCom,
                           org.apache.hadoop.mapreduce.JobContext context)
                    throws java.io.IOException

Throws:

java.io.IOException

Method Detail

commitJob

public void commitJob(org.apache.hadoop.mapreduce.JobContext context)
               throws java.io.IOException

Overrides:

commitJob in class WrapperOutputCommitter

Throws:

java.io.IOException