org.apache.hadoop.hive.ql.io.rcfile.merge
Class RCFileBlockMergeRecordReader

java.lang.Object
  org.apache.hadoop.hive.ql.io.rcfile.merge.RCFileBlockMergeRecordReader

All Implemented Interfaces:

org.apache.hadoop.mapred.RecordReader<RCFileKeyBufferWrapper,RCFileValueBufferWrapper>

public class RCFileBlockMergeRecordReader
extends Object
implements org.apache.hadoop.mapred.RecordReader<RCFileKeyBufferWrapper,RCFileValueBufferWrapper>

Constructor Summary

RCFileBlockMergeRecordReader(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.mapred.FileSplit split)

Method Summary

void	close()
RCFileKeyBufferWrapper	createKey()
RCFileValueBufferWrapper	createValue()
Class<?>	getKeyClass()
long	getPos()
float	getProgress() Return the progress within the input split.
long	getStart()
Class<?>	getValueClass()
boolean	next(RCFileKeyBufferWrapper key, RCFileValueBufferWrapper value)

Methods inherited from class java.lang.Object

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

Constructor Detail

RCFileBlockMergeRecordReader

public RCFileBlockMergeRecordReader(org.apache.hadoop.conf.Configuration conf,
                                    org.apache.hadoop.mapred.FileSplit split)
                             throws IOException

Throws:

IOException

Method Detail

getKeyClass

public Class<?> getKeyClass()

getValueClass

public Class<?> getValueClass()

createKey

public RCFileKeyBufferWrapper createKey()

Specified by:

createKey in interface org.apache.hadoop.mapred.RecordReader<RCFileKeyBufferWrapper,RCFileValueBufferWrapper>

createValue

public RCFileValueBufferWrapper createValue()

Specified by:

createValue in interface org.apache.hadoop.mapred.RecordReader<RCFileKeyBufferWrapper,RCFileValueBufferWrapper>

next

public boolean next(RCFileKeyBufferWrapper key,
                    RCFileValueBufferWrapper value)
             throws IOException

Specified by:

next in interface org.apache.hadoop.mapred.RecordReader<RCFileKeyBufferWrapper,RCFileValueBufferWrapper>

Throws:

IOException

getProgress

public float getProgress()
                  throws IOException

Return the progress within the input split.

Specified by:

getProgress in interface org.apache.hadoop.mapred.RecordReader<RCFileKeyBufferWrapper,RCFileValueBufferWrapper>

Returns:

0.0 to 1.0 of the input byte range

Throws:

IOException

getPos

public long getPos()
            throws IOException

Specified by:

getPos in interface org.apache.hadoop.mapred.RecordReader<RCFileKeyBufferWrapper,RCFileValueBufferWrapper>

Throws:

IOException

getStart

public long getStart()

close

public void close()
           throws IOException

Specified by:

close in interface org.apache.hadoop.mapred.RecordReader<RCFileKeyBufferWrapper,RCFileValueBufferWrapper>

Throws:

IOException