org.apache.tez.mapreduce.output
Class MROutput

java.lang.Object
  org.apache.tez.mapreduce.output.MROutput

All Implemented Interfaces:

org.apache.tez.runtime.api.LogicalOutput, org.apache.tez.runtime.api.Output

Direct Known Subclasses:

MROutputLegacy

public class MROutput
extends Object
implements org.apache.tez.runtime.api.LogicalOutput

Field Summary

protected org.apache.hadoop.mapreduce.OutputCommitter

committer

Constructor Summary

MROutput()

Method Summary

void	abort() MROutput expects that a Processor call abort in case of any error ( including an error during commit ) prior to the Processor's completion
List<org.apache.tez.runtime.api.Event>	close()
void	commit() MROutput expects that a Processor call commit prior to the Processor's completion
org.apache.tez.runtime.library.api.KeyValueWriter	getWriter()
void	handleEvents(List<org.apache.tez.runtime.api.Event> outputEvents)
void	initCommitter(org.apache.hadoop.mapred.JobConf job, boolean useNewApi)
List<org.apache.tez.runtime.api.Event>	initialize(org.apache.tez.runtime.api.TezOutputContext outputContext)
boolean	isCommitRequired()
void	setNumPhysicalOutputs(int numOutputs)
void	start()

Methods inherited from class java.lang.Object

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

Field Detail

committer

protected org.apache.hadoop.mapreduce.OutputCommitter committer

Constructor Detail

MROutput

public MROutput()

Method Detail

initialize

public List<org.apache.tez.runtime.api.Event> initialize(org.apache.tez.runtime.api.TezOutputContext outputContext)
                                                  throws IOException,
                                                         InterruptedException

Specified by:

initialize in interface org.apache.tez.runtime.api.Output

Throws:

IOException

InterruptedException

start

public void start()

Specified by:

start in interface org.apache.tez.runtime.api.Output

initCommitter

public void initCommitter(org.apache.hadoop.mapred.JobConf job,
                          boolean useNewApi)
                   throws IOException,
                          InterruptedException

Throws:

IOException

InterruptedException

isCommitRequired

public boolean isCommitRequired()
                         throws IOException

Throws:

IOException

getWriter

public org.apache.tez.runtime.library.api.KeyValueWriter getWriter()
                                                            throws IOException

Specified by:

getWriter in interface org.apache.tez.runtime.api.Output

Throws:

IOException

handleEvents

public void handleEvents(List<org.apache.tez.runtime.api.Event> outputEvents)

Specified by:

handleEvents in interface org.apache.tez.runtime.api.Output

close

public List<org.apache.tez.runtime.api.Event> close()
                                             throws IOException

Specified by:

close in interface org.apache.tez.runtime.api.Output

Throws:

IOException

setNumPhysicalOutputs

public void setNumPhysicalOutputs(int numOutputs)

Specified by:

setNumPhysicalOutputs in interface org.apache.tez.runtime.api.LogicalOutput

commit

public void commit()
            throws IOException

MROutput expects that a Processor call commit prior to the Processor's completion

Throws:

IOException

abort

public void abort()
           throws IOException

MROutput expects that a Processor call abort in case of any error ( including an error during commit ) prior to the Processor's completion

Throws:

IOException