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

Field Summary

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

completedProcessing

Constructor Summary

Constructors

Constructor and Description
MRReader(org.apache.tez.runtime.api.InputContext context)

Method Summary

Methods

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

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

getCurrentKey, getCurrentValue, hasCompletedProcessing, next

Methods inherited from class java.lang.Object

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

Constructor Detail

MRReader

public MRReader(org.apache.tez.runtime.api.InputContext context)

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()

notifyProgress

protected final void notifyProgress()

notifyDone

protected final void notifyDone()