org.apache.hadoop.hive.ql.io

Class RCFileRecordReader<K extends LongWritable,V extends BytesRefArrayWritable>

java.lang.Object

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

Type Parameters:

K -

V -

public class RCFileRecordReader<K extends LongWritable,V extends BytesRefArrayWritable>
extends java.lang.Object

RCFileRecordReader.

Field Summary

Fields

Modifier and Type	Field and Description
protected Configuration	conf

Constructor Summary

Constructors

Constructor and Description
RCFileRecordReader(Configuration conf, FileSplit split)

Method Summary

Modifier and Type	Method and Description
void	close()
LongWritable	createKey()
BytesRefArrayWritable	createValue()
RCFile.KeyBuffer	getKeyBuffer()
java.lang.Class<?>	getKeyClass()
long	getPos()
float	getProgress() Return the progress within the input split.
long	getStart()
java.lang.Class<?>	getValueClass()
protected boolean	next(LongWritable key)
boolean	next(LongWritable key, BytesRefArrayWritable value)
boolean	nextBlock()
void	resetBuffer()
protected void	seek(long pos)
void	sync(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

RCFileRecordReader

public RCFileRecordReader(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 LongWritable createKey()

createValue

public BytesRefArrayWritable createValue()

nextBlock

public boolean nextBlock()
                  throws java.io.IOException

Throws:

java.io.IOException

next

public boolean next(LongWritable key,
                    BytesRefArrayWritable value)
             throws java.io.IOException

Throws:

java.io.IOException

next

protected boolean next(LongWritable key)
                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

getKeyBuffer

public RCFile.KeyBuffer getKeyBuffer()

seek

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

Throws:

java.io.IOException

sync

public void sync(long pos)
          throws java.io.IOException

Throws:

java.io.IOException

resetBuffer

public void resetBuffer()

getStart

public long getStart()

close

public void close()
           throws java.io.IOException

Throws:

java.io.IOException