org.apache.tez.mapreduce.lib

Class MRReaderMapred

java.lang.Object

org.apache.tez.runtime.api.Reader

org.apache.tez.runtime.library.api.KeyValueReader

org.apache.tez.mapreduce.lib.MRReader

org.apache.tez.mapreduce.lib.MRReaderMapred

public class MRReaderMapred
extends MRReader

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.hadoop.mapred.InputSplit	inputSplit
protected org.apache.hadoop.mapred.RecordReader	recordReader

Fields inherited from class org.apache.tez.runtime.library.api.KeyValueReader

completedProcessing

Constructor Summary

Constructors

Constructor and Description
MRReaderMapred(org.apache.hadoop.mapred.JobConf jobConf, org.apache.hadoop.mapred.InputSplit inputSplit, org.apache.tez.common.counters.TezCounters tezCounters, org.apache.tez.common.counters.TezCounter inputRecordCounter, org.apache.tez.runtime.api.InputContext context)
MRReaderMapred(org.apache.hadoop.mapred.JobConf jobConf, org.apache.tez.common.counters.TezCounters tezCounters, org.apache.tez.common.counters.TezCounter inputRecordCounter, org.apache.tez.runtime.api.InputContext context)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
org.apache.hadoop.conf.Configuration	getConfigUpdates() MRInput sets some additional parameters like split location when using the new API.
Object	getCurrentKey()
Object	getCurrentValue()
float	getProgress()
Object	getRecordReader()
Object	getSplit()
boolean	isSetup()
boolean	next()
void	setSplit(Object inputSplit)

Methods inherited from class org.apache.tez.mapreduce.lib.MRReader

notifyDone, notifyProgress

Methods inherited from class org.apache.tez.runtime.library.api.KeyValueReader

hasCompletedProcessing

Methods inherited from class java.lang.Object

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

Field Detail

inputSplit

protected org.apache.hadoop.mapred.InputSplit inputSplit

recordReader

protected org.apache.hadoop.mapred.RecordReader recordReader

Constructor Detail

MRReaderMapred

public MRReaderMapred(org.apache.hadoop.mapred.JobConf jobConf,
              org.apache.tez.common.counters.TezCounters tezCounters,
              org.apache.tez.common.counters.TezCounter inputRecordCounter,
              org.apache.tez.runtime.api.InputContext context)
               throws IOException

Throws:

IOException

MRReaderMapred

public MRReaderMapred(org.apache.hadoop.mapred.JobConf jobConf,
              org.apache.hadoop.mapred.InputSplit inputSplit,
              org.apache.tez.common.counters.TezCounters tezCounters,
              org.apache.tez.common.counters.TezCounter inputRecordCounter,
              org.apache.tez.runtime.api.InputContext context)
               throws IOException

Throws:

IOException

Method Detail

setSplit

public void setSplit(Object inputSplit)
              throws IOException

Specified by:

setSplit in class MRReader

Throws:

IOException

isSetup

public boolean isSetup()

Specified by:

isSetup in class MRReader

getProgress

public float getProgress()
                  throws IOException,
                         InterruptedException

Specified by:

getProgress in class MRReader

Throws:

IOException

InterruptedException

close

public void close()
           throws IOException

Specified by:

close in class MRReader

Throws:

IOException

getSplit

public Object getSplit()

Specified by:

getSplit in class MRReader

getRecordReader

public Object getRecordReader()

Specified by:

getRecordReader in class MRReader

next

public boolean next()
             throws IOException

Specified by:

next in class org.apache.tez.runtime.library.api.KeyValueReader

Throws:

IOException

getCurrentKey

public Object getCurrentKey()
                     throws IOException

Specified by:

getCurrentKey in class org.apache.tez.runtime.library.api.KeyValueReader

Throws:

IOException

getCurrentValue

public Object getCurrentValue()
                       throws IOException

Specified by:

getCurrentValue in class org.apache.tez.runtime.library.api.KeyValueReader

Throws:

IOException

getConfigUpdates

public org.apache.hadoop.conf.Configuration getConfigUpdates()

MRInput sets some additional parameters like split location when using the new API. This methods returns the list of additional updates, and should be used by Processors using the old MapReduce API with MRInput.

Returns:

the additional fields set by MRInput