org.apache.hive.hcatalog.rcfile

Class RCFileMapReduceRecordReader<K extends LongWritable,V extends BytesRefArrayWritable>

java.lang.Object

<any>

org.apache.hive.hcatalog.rcfile.RCFileMapReduceRecordReader<K,V>

public class RCFileMapReduceRecordReader<K extends LongWritable,V extends BytesRefArrayWritable>
extends <any>

Constructor Summary

Constructors

Constructor and Description
RCFileMapReduceRecordReader()

Method Summary

Modifier and Type	Method and Description
void	close()
LongWritable	getCurrentKey()
BytesRefArrayWritable	getCurrentValue()
float	getProgress()
void	initialize(InputSplit split, TaskAttemptContext context)
boolean	nextKeyValue()

Methods inherited from class java.lang.Object

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

Constructor Detail

RCFileMapReduceRecordReader

public RCFileMapReduceRecordReader()

Method Detail

close

public void close()
           throws java.io.IOException

Throws:

java.io.IOException

getCurrentKey

public LongWritable getCurrentKey()
                           throws java.io.IOException,
                                  java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

getCurrentValue

public BytesRefArrayWritable getCurrentValue()
                                      throws java.io.IOException,
                                             java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

getProgress

public float getProgress()
                  throws java.io.IOException,
                         java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

nextKeyValue

public boolean nextKeyValue()
                     throws java.io.IOException,
                            java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

initialize

public void initialize(InputSplit split,
                       TaskAttemptContext context)
                throws java.io.IOException,
                       java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException