org.apache.hadoop.hive.ql.io.orc

Class OrcOiBatchToRowReader

java.lang.Object

org.apache.hadoop.hive.ql.io.BatchToRowReader<OrcStruct,org.apache.hadoop.hive.ql.io.orc.OrcUnion>

org.apache.hadoop.hive.ql.io.orc.OrcOiBatchToRowReader

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,Object>

public class OrcOiBatchToRowReader
extends BatchToRowReader<OrcStruct,org.apache.hadoop.hive.ql.io.orc.OrcUnion>

BatchToRowReader that returns the rows readable by ORC IOs.

Field Summary

Fields inherited from class org.apache.hadoop.hive.ql.io.BatchToRowReader

LOG

Constructor Summary

Constructors

Constructor and Description
OrcOiBatchToRowReader(org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch> vrbReader, VectorizedRowBatchCtx vrbCtx, List<Integer> includedCols)

Method Summary

Modifier and Type	Method and Description
protected OrcStruct	createStructObject(Object previous, List<TypeInfo> childrenTypes)
protected org.apache.hadoop.hive.ql.io.orc.OrcUnion	createUnionObject(List<TypeInfo> childrenTypes, Object previous)
protected Object	getStructCol(OrcStruct structObj, int i)
protected Object	getUnionField(org.apache.hadoop.hive.ql.io.orc.OrcUnion unionObj)
protected void	setStructCol(OrcStruct structObj, int i, Object value)
protected void	setUnion(org.apache.hadoop.hive.ql.io.orc.OrcUnion unionObj, byte tag, Object object)

Methods inherited from class org.apache.hadoop.hive.ql.io.BatchToRowReader

close, createKey, createValue, getPos, getProgress, next, nextBinary, nextBoolean, nextByte, nextChar, nextDate, nextDecimal, nextDouble, nextFloat, nextInt, nextLong, nextShort, nextString, nextStruct, nextTimestamp, nextVarchar

Methods inherited from class java.lang.Object

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

Constructor Detail

OrcOiBatchToRowReader

public OrcOiBatchToRowReader(org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch> vrbReader,
                             VectorizedRowBatchCtx vrbCtx,
                             List<Integer> includedCols)

Method Detail

createStructObject

protected OrcStruct createStructObject(Object previous,
                                       List<TypeInfo> childrenTypes)

Specified by:

createStructObject in class BatchToRowReader<OrcStruct,org.apache.hadoop.hive.ql.io.orc.OrcUnion>

createUnionObject

protected org.apache.hadoop.hive.ql.io.orc.OrcUnion createUnionObject(List<TypeInfo> childrenTypes,
                                                                      Object previous)

Specified by:

createUnionObject in class BatchToRowReader<OrcStruct,org.apache.hadoop.hive.ql.io.orc.OrcUnion>

setStructCol

protected void setStructCol(OrcStruct structObj,
                            int i,
                            Object value)

Specified by:

setStructCol in class BatchToRowReader<OrcStruct,org.apache.hadoop.hive.ql.io.orc.OrcUnion>

getStructCol

protected Object getStructCol(OrcStruct structObj,
                              int i)

Specified by:

getStructCol in class BatchToRowReader<OrcStruct,org.apache.hadoop.hive.ql.io.orc.OrcUnion>

getUnionField

protected Object getUnionField(org.apache.hadoop.hive.ql.io.orc.OrcUnion unionObj)

Specified by:

getUnionField in class BatchToRowReader<OrcStruct,org.apache.hadoop.hive.ql.io.orc.OrcUnion>

setUnion

protected void setUnion(org.apache.hadoop.hive.ql.io.orc.OrcUnion unionObj,
                        byte tag,
                        Object object)

Specified by:

setUnion in class BatchToRowReader<OrcStruct,org.apache.hadoop.hive.ql.io.orc.OrcUnion>