org.apache.hadoop.hive.ql.io

Class CombineHiveRecordReader<K extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.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 -

All Implemented Interfaces:

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

public class CombineHiveRecordReader<K extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.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(org.apache.hadoop.mapred.InputSplit split, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.mapred.Reporter reporter, Integer partition)

Method Summary

Methods

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, 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(org.apache.hadoop.mapred.InputSplit split,
                       org.apache.hadoop.conf.Configuration conf,
                       org.apache.hadoop.mapred.Reporter reporter,
                       Integer partition)
                        throws IOException

Throws:

IOException

Method Detail

doClose

public void doClose()
             throws IOException

Description copied from class: HiveContextAwareRecordReader

Close this InputSplit to future operations.

Specified by:

doClose in class HiveContextAwareRecordReader<K extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable>

Throws:

IOException

createKey

public K createKey()

createValue

public V createValue()

getPos

public long getPos()
            throws IOException

Throws:

IOException

getProgress

public float getProgress()
                  throws IOException

Specified by:

getProgress in interface org.apache.hadoop.mapred.RecordReader<K extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable>

Overrides:

getProgress in class HiveContextAwareRecordReader<K extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable>

Throws:

IOException

doNext

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

Overrides:

doNext in class HiveContextAwareRecordReader<K extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable>

Throws:

IOException