Package org.apache.orc.mapred

Class OrcMapredRecordReader<V extends WritableComparable>

java.lang.Object

org.apache.orc.mapred.OrcMapredRecordReader<V>

Type Parameters:

V - the root type of the file

All Implemented Interfaces:

Closeable, AutoCloseable, RecordReader<NullWritable,V>

public class OrcMapredRecordReader<V extends WritableComparable>
extends Object
implements RecordReader<NullWritable,V>

This record reader implements the org.apache.hadoop.mapred API.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	OrcMapredRecordReader(Reader fileReader, Reader.Options options)
protected	OrcMapredRecordReader(Reader fileReader, Reader.Options options, int rowBatchSize)
	OrcMapredRecordReader(RecordReader reader, TypeDescription schema)

Method Summary

Modifier and Type	Method	Description
void	close()
NullWritable	createKey()
V	createValue()
long	getPos()
float	getProgress()
boolean	next(NullWritable key, V value)
static WritableComparable	nextValue(org.apache.hadoop.hive.ql.exec.vector.ColumnVector vector, int row, TypeDescription schema, Object previous)

Methods inherited from class java.lang.Object

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

Constructor Details

OrcMapredRecordReader

public OrcMapredRecordReader(RecordReader reader,
 TypeDescription schema)
                      throws IOException

Throws:

IOException

OrcMapredRecordReader

protected OrcMapredRecordReader(Reader fileReader,
 Reader.Options options)
                         throws IOException

Throws:

IOException

OrcMapredRecordReader

protected OrcMapredRecordReader(Reader fileReader,
 Reader.Options options,
 int rowBatchSize)
                         throws IOException

Throws:

IOException

Method Details

next

public boolean next(NullWritable key,
 V value)
             throws IOException

Specified by:

next in interface RecordReader<NullWritable,V extends WritableComparable>

Throws:

IOException

createKey

public NullWritable createKey()

Specified by:

createKey in interface RecordReader<NullWritable,V extends WritableComparable>

createValue

public V createValue()

Specified by:

createValue in interface RecordReader<NullWritable,V extends WritableComparable>

getPos

public long getPos()
            throws IOException

Specified by:

getPos in interface RecordReader<NullWritable,V extends WritableComparable>

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface RecordReader<NullWritable,V extends WritableComparable>

Throws:

IOException

getProgress

public float getProgress()
                  throws IOException

Specified by:

getProgress in interface RecordReader<NullWritable,V extends WritableComparable>

Throws:

IOException

nextValue

public static WritableComparable nextValue(org.apache.hadoop.hive.ql.exec.vector.ColumnVector vector,
 int row,
 TypeDescription schema,
 Object previous)