org.apache.hadoop.mapred.split
Class TezGroupedSplitsInputFormat.TezGroupedSplitsRecordReader

java.lang.Object
  org.apache.hadoop.mapred.split.TezGroupedSplitsInputFormat.TezGroupedSplitsRecordReader

All Implemented Interfaces:

org.apache.hadoop.mapred.RecordReader<K,V>

Enclosing class:

TezGroupedSplitsInputFormat<K,V>

public class TezGroupedSplitsInputFormat.TezGroupedSplitsRecordReader
extends Object
implements org.apache.hadoop.mapred.RecordReader<K,V>

Constructor Summary

TezGroupedSplitsInputFormat.TezGroupedSplitsRecordReader(TezGroupedSplit split, org.apache.hadoop.mapred.JobConf job, org.apache.hadoop.mapred.Reporter reporter)

Method Summary

void	close()
K	createKey()
V	createValue()
long	getPos()
float	getProgress()
protected boolean	initNextRecordReader()
boolean	next(K key, V value)

Methods inherited from class java.lang.Object

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

Constructor Detail

TezGroupedSplitsInputFormat.TezGroupedSplitsRecordReader

public TezGroupedSplitsInputFormat.TezGroupedSplitsRecordReader(TezGroupedSplit split,
                                                                org.apache.hadoop.mapred.JobConf job,
                                                                org.apache.hadoop.mapred.Reporter reporter)
                                                         throws IOException

Throws:

IOException

Method Detail

next

public boolean next(K key,
                    V value)
             throws IOException

Specified by:

next in interface org.apache.hadoop.mapred.RecordReader<K,V>

Throws:

IOException

createKey

public K createKey()

Specified by:

createKey in interface org.apache.hadoop.mapred.RecordReader<K,V>

createValue

public V createValue()

Specified by:

createValue in interface org.apache.hadoop.mapred.RecordReader<K,V>

getProgress

public float getProgress()
                  throws IOException

Specified by:

getProgress in interface org.apache.hadoop.mapred.RecordReader<K,V>

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface org.apache.hadoop.mapred.RecordReader<K,V>

Throws:

IOException

initNextRecordReader

protected boolean initNextRecordReader()
                                throws IOException

Throws:

IOException

getPos

public long getPos()
            throws IOException

Specified by:

getPos in interface org.apache.hadoop.mapred.RecordReader<K,V>

Throws:

IOException