org.apache.tez.mapreduce.committer
Class MROutputCommitter

java.lang.Object
  org.apache.tez.runtime.api.OutputCommitter
      org.apache.tez.mapreduce.committer.MROutputCommitter

public class MROutputCommitter
extends org.apache.tez.runtime.api.OutputCommitter

Constructor Summary

MROutputCommitter()

Method Summary

void	abortOutput(org.apache.tez.dag.api.client.VertexStatus.State finalState)
void	commitOutput()
void	initialize(org.apache.tez.runtime.api.OutputCommitterContext context)
boolean	isTaskRecoverySupported()
void	recoverTask(int taskIndex, int attemptId)
void	setupOutput()

Methods inherited from class java.lang.Object

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

Constructor Detail

MROutputCommitter

public MROutputCommitter()

Method Detail

initialize

public void initialize(org.apache.tez.runtime.api.OutputCommitterContext context)
                throws IOException

Specified by:

initialize in class org.apache.tez.runtime.api.OutputCommitter

Throws:

IOException

setupOutput

public void setupOutput()
                 throws IOException

Specified by:

setupOutput in class org.apache.tez.runtime.api.OutputCommitter

Throws:

IOException

commitOutput

public void commitOutput()
                  throws IOException

Specified by:

commitOutput in class org.apache.tez.runtime.api.OutputCommitter

Throws:

IOException

abortOutput

public void abortOutput(org.apache.tez.dag.api.client.VertexStatus.State finalState)
                 throws IOException

Specified by:

abortOutput in class org.apache.tez.runtime.api.OutputCommitter

Throws:

IOException

isTaskRecoverySupported

public boolean isTaskRecoverySupported()

Overrides:

isTaskRecoverySupported in class org.apache.tez.runtime.api.OutputCommitter

recoverTask

public void recoverTask(int taskIndex,
                        int attemptId)
                 throws IOException

Overrides:

recoverTask in class org.apache.tez.runtime.api.OutputCommitter

Throws:

IOException