org.apache.tez.mapreduce.committer

Class MROutputCommitter

java.lang.Object

org.apache.tez.runtime.api.OutputCommitter

org.apache.tez.mapreduce.committer.MROutputCommitter

@InterfaceAudience.Public
public class MROutputCommitter
extends org.apache.tez.runtime.api.OutputCommitter

Implements the OutputCommitter and provide Map Reduce compatible output commit operations for Map Reduce compatible data sinks.

Constructor Summary

Constructors

Constructor and Description
MROutputCommitter(org.apache.tez.runtime.api.OutputCommitterContext committerContext)

Method Summary

Methods

Modifier and Type	Method and Description
void	abortOutput(org.apache.tez.dag.api.client.VertexStatus.State finalState)
void	commitOutput()
void	initialize()
boolean	isTaskRecoverySupported()
void	recoverTask(int taskIndex, int attemptId)
void	setupOutput()

Methods inherited from class org.apache.tez.runtime.api.OutputCommitter

getContext

Methods inherited from class java.lang.Object

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

Constructor Detail

MROutputCommitter

public MROutputCommitter(org.apache.tez.runtime.api.OutputCommitterContext committerContext)

Method Detail

initialize

public void initialize()
                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