org.apache.tez.mapreduce.lib

Class MRReader

java.lang.Object

org.apache.tez.runtime.api.Reader

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

org.apache.tez.mapreduce.lib.MRReader

Direct Known Subclasses:

MRReaderMapred, MRReaderMapReduce

@InterfaceAudience.Private
public abstract class MRReader
extends org.apache.tez.runtime.library.api.KeyValueReader

Constructor Summary

Constructors

Constructor and Description
MRReader()

Method Summary

Methods

Modifier and Type	Method and Description
abstract void	close()
abstract float	getProgress()
abstract Object	getRecordReader()
abstract Object	getSplit()
abstract boolean	isSetup()
abstract void	setSplit(Object split)

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

getCurrentKey, getCurrentValue, next

Methods inherited from class java.lang.Object

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

Constructor Detail

MRReader

public MRReader()

Method Detail

setSplit

public abstract void setSplit(Object split)
                       throws IOException

Throws:

IOException

isSetup

public abstract boolean isSetup()

getProgress

public abstract float getProgress()
                           throws IOException,
                                  InterruptedException

Throws:

IOException

InterruptedException

close

public abstract void close()
                    throws IOException

Throws:

IOException

getSplit

public abstract Object getSplit()

getRecordReader

public abstract Object getRecordReader()