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

Class RCFileBlockMergeRecordReader

java.lang.Object

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

public class RCFileBlockMergeRecordReader
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
protected Configuration	conf

Constructor Summary

Constructors

Constructor and Description
RCFileBlockMergeRecordReader(Configuration conf, FileSplit split)

Method Summary

Modifier and Type	Method and Description
void	close()
RCFileKeyBufferWrapper	createKey()
RCFileValueBufferWrapper	createValue()
java.lang.Class<?>	getKeyClass()
long	getPos()
float	getProgress() Return the progress within the input split.
long	getStart()
java.lang.Class<?>	getValueClass()
boolean	next(RCFileKeyBufferWrapper key, RCFileValueBufferWrapper value)
protected boolean	nextBlock(RCFileKeyBufferWrapper keyWrapper, RCFileValueBufferWrapper valueWrapper)
protected void	seek(long pos)

Methods inherited from class java.lang.Object

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

Field Detail

conf

protected Configuration conf

Constructor Detail

RCFileBlockMergeRecordReader

public RCFileBlockMergeRecordReader(Configuration conf,
                                    FileSplit split)
                             throws java.io.IOException

Throws:

java.io.IOException

Method Detail

getKeyClass

public java.lang.Class<?> getKeyClass()

getValueClass

public java.lang.Class<?> getValueClass()

createKey

public RCFileKeyBufferWrapper createKey()

createValue

public RCFileValueBufferWrapper createValue()

next

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

Throws:

java.io.IOException

nextBlock

protected boolean nextBlock(RCFileKeyBufferWrapper keyWrapper,
                            RCFileValueBufferWrapper valueWrapper)
                     throws java.io.IOException

Throws:

java.io.IOException

getProgress

public float getProgress()
                  throws java.io.IOException

Return the progress within the input split.

Returns:

0.0 to 1.0 of the input byte range

Throws:

java.io.IOException

getPos

public long getPos()
            throws java.io.IOException

Throws:

java.io.IOException

seek

protected void seek(long pos)
             throws java.io.IOException

Throws:

java.io.IOException

getStart

public long getStart()

close

public void close()
           throws java.io.IOException

Throws:

java.io.IOException