org.apache.hadoop.hive.ql.io

Class CombineHiveRecordReader<K extends WritableComparable,V extends Writable>

java.lang.Object

org.apache.hadoop.hive.ql.io.HiveContextAwareRecordReader<K,V>

org.apache.hadoop.hive.ql.io.CombineHiveRecordReader<K,V>

Type Parameters:

K -

V -

public class CombineHiveRecordReader<K extends WritableComparable,V extends Writable>
extends HiveContextAwareRecordReader<K,V>

CombineHiveRecordReader.

Field Summary

Fields inherited from class org.apache.hadoop.hive.ql.io.HiveContextAwareRecordReader

isSorted, jobConf, recordReader

Constructor Summary

Constructors

Constructor and Description
CombineHiveRecordReader(InputSplit split, Configuration conf, Reporter reporter, java.lang.Integer partition)

Method Summary

Modifier and Type	Method and Description
K	createKey()
V	createValue()
void	doClose() Close this InputSplit to future operations.
boolean	doNext(K key, V value)
long	getPos()
float	getProgress()

Methods inherited from class org.apache.hadoop.hive.ql.io.HiveContextAwareRecordReader

close, foundAllTargets, getIOContext, initIOContext, initIOContext, initIOContext, initIOContextSortedProps, next, setRecordReader, updateIOContext

Methods inherited from class java.lang.Object

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

Constructor Detail

CombineHiveRecordReader

public CombineHiveRecordReader(InputSplit split,
                               Configuration conf,
                               Reporter reporter,
                               java.lang.Integer partition)
                        throws java.io.IOException

Throws:

java.io.IOException

Method Detail

doClose

public void doClose()
             throws java.io.IOException

Description copied from class: HiveContextAwareRecordReader

Close this InputSplit to future operations.

Specified by:

doClose in class HiveContextAwareRecordReader<K extends WritableComparable,V extends Writable>

Throws:

java.io.IOException

createKey

public K createKey()

createValue

public V createValue()

getPos

public long getPos()
            throws java.io.IOException

Throws:

java.io.IOException

getProgress

public float getProgress()
                  throws java.io.IOException

Overrides:

getProgress in class HiveContextAwareRecordReader<K extends WritableComparable,V extends Writable>

Throws:

java.io.IOException

doNext

public boolean doNext(K key,
                      V value)
               throws java.io.IOException

Overrides:

doNext in class HiveContextAwareRecordReader<K extends WritableComparable,V extends Writable>

Throws:

java.io.IOException