org.apache.tez.mapreduce.input.base

Class MRInputBase

java.lang.Object

org.apache.tez.runtime.api.AbstractLogicalInput

org.apache.tez.mapreduce.input.base.MRInputBase

All Implemented Interfaces:

org.apache.tez.runtime.api.Input, org.apache.tez.runtime.api.InputFrameworkInterface, org.apache.tez.runtime.api.LogicalInput, org.apache.tez.runtime.api.LogicalInputFrameworkInterface

Direct Known Subclasses:

MRInput, MultiMRInput

@InterfaceAudience.Private
public abstract class MRInputBase
extends org.apache.tez.runtime.api.AbstractLogicalInput

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.tez.common.counters.TezCounter	inputRecordCounter
protected org.apache.hadoop.mapred.JobConf	jobConf
protected boolean	useNewApi

Constructor Summary

Constructors

Constructor and Description
MRInputBase(org.apache.tez.runtime.api.InputContext inputContext, int numPhysicalInputs)

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.tez.runtime.api.Reader	getReader()
List<org.apache.tez.runtime.api.Event>	initialize()

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

getContext, getNumPhysicalInputs

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.tez.runtime.api.Input

start

Methods inherited from interface org.apache.tez.runtime.api.InputFrameworkInterface

close, handleEvents

Field Detail

jobConf

protected org.apache.hadoop.mapred.JobConf jobConf

inputRecordCounter

protected org.apache.tez.common.counters.TezCounter inputRecordCounter

useNewApi

@InterfaceAudience.Private
protected boolean useNewApi

Constructor Detail

MRInputBase

public MRInputBase(org.apache.tez.runtime.api.InputContext inputContext,
           int numPhysicalInputs)

Method Detail

getReader

public org.apache.tez.runtime.api.Reader getReader()
                                            throws Exception

Throws:

Exception

initialize

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

Specified by:

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

Specified by:

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

Throws:

IOException