org.apache.sysml.runtime.matrix.data

Class MultipleOutputCommitter

java.lang.Object

org.apache.hadoop.mapreduce.OutputCommitter

org.apache.hadoop.mapred.OutputCommitter

org.apache.hadoop.mapred.FileOutputCommitter

org.apache.sysml.runtime.matrix.data.MultipleOutputCommitter

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

Field Summary

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

LOG, SUCCEEDED_FILE_NAME, TEMP_DIR_NAME

Constructor Summary

Constructors

Constructor and Description
MultipleOutputCommitter()

Method Summary

Modifier and Type	Method and Description
void	cleanupJob(org.apache.hadoop.mapred.JobContext context)
void	commitTask(org.apache.hadoop.mapred.TaskAttemptContext context)
void	setupJob(org.apache.hadoop.mapred.JobContext context)

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

abortJob, abortTask, commitJob, getTaskAttemptPath, getWorkPath, isRecoverySupported, isRecoverySupported, needsTaskCommit, recoverTask, 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

MultipleOutputCommitter

public MultipleOutputCommitter()

Method Detail

setupJob

public void setupJob(org.apache.hadoop.mapred.JobContext context)
              throws IOException

Overrides:

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

Throws:

IOException

cleanupJob

public void cleanupJob(org.apache.hadoop.mapred.JobContext context)
                throws IOException

Overrides:

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

Throws:

IOException

commitTask

public void commitTask(org.apache.hadoop.mapred.TaskAttemptContext context)
                throws IOException

Overrides:

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

Throws:

IOException