org.apache.tez.mapreduce.lib

Class MRReaderMapReduce

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.MRReaderMapReduce

public class MRReaderMapReduce
extends MRReader

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.hadoop.mapreduce.RecordReader	recordReader

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

completedProcessing

Constructor Summary

Constructors

Constructor and Description
MRReaderMapReduce(org.apache.hadoop.mapred.JobConf jobConf, org.apache.hadoop.mapreduce.InputSplit inputSplit, org.apache.tez.common.counters.TezCounters tezCounters, org.apache.tez.common.counters.TezCounter inputRecordCounter, long clusterId, int vertexIndex, int appId, int taskIndex, int taskAttemptNumber, org.apache.tez.runtime.api.InputContext context)
MRReaderMapReduce(org.apache.hadoop.mapred.JobConf jobConf, org.apache.tez.common.counters.TezCounters tezCounters, org.apache.tez.common.counters.TezCounter inputRecordCounter, long clusterId, int vertexIndex, int appId, int taskIndex, int taskAttemptNumber, org.apache.tez.runtime.api.InputContext context)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
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

recordReader

protected org.apache.hadoop.mapreduce.RecordReader recordReader

Constructor Detail

MRReaderMapReduce

public MRReaderMapReduce(org.apache.hadoop.mapred.JobConf jobConf,
                 org.apache.tez.common.counters.TezCounters tezCounters,
                 org.apache.tez.common.counters.TezCounter inputRecordCounter,
                 long clusterId,
                 int vertexIndex,
                 int appId,
                 int taskIndex,
                 int taskAttemptNumber,
                 org.apache.tez.runtime.api.InputContext context)
                  throws IOException

Throws:

IOException

MRReaderMapReduce

public MRReaderMapReduce(org.apache.hadoop.mapred.JobConf jobConf,
                 org.apache.hadoop.mapreduce.InputSplit inputSplit,
                 org.apache.tez.common.counters.TezCounters tezCounters,
                 org.apache.tez.common.counters.TezCounter inputRecordCounter,
                 long clusterId,
                 int vertexIndex,
                 int appId,
                 int taskIndex,
                 int taskAttemptNumber,
                 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