oracle.spatial.hadoop.vector.join.mapred

Class JoinOutputCommitter

java.lang.Object

org.apache.hadoop.mapreduce.OutputCommitter

org.apache.hadoop.mapred.OutputCommitter

org.apache.hadoop.mapred.FileOutputCommitter

oracle.spatial.hadoop.vector.join.mapred.JoinOutputCommitter

public class JoinOutputCommitter
extends org.apache.hadoop.mapred.FileOutputCommitter

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

Field Summary

Fields inherited from class org.apache.hadoop.mapred.FileOutputCommitter

LOG, SUCCEEDED_FILE_NAME, TEMP_DIR_NAME

Constructor Summary

Constructors

Constructor and Description
JoinOutputCommitter()

Method Summary

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

Methods inherited from class org.apache.hadoop.mapred.FileOutputCommitter

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

Methods inherited from class org.apache.hadoop.mapred.OutputCommitter

abortJob, abortTask, cleanupJob, commitJob, commitTask, isRecoverySupported, needsTaskCommit, recoverTask, setupJob, setupTask

Methods inherited from class java.lang.Object

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

Constructor Detail

JoinOutputCommitter

public JoinOutputCommitter()

Method Detail

commitJob

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

Overrides:

commitJob in class org.apache.hadoop.mapred.FileOutputCommitter

Throws:

java.io.IOException