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

Class Reader.OrcEncodedColumnBatch

java.lang.Object

org.apache.hadoop.hive.common.io.encoded.EncodedColumnBatch<OrcBatchKey>

org.apache.hadoop.hive.ql.io.orc.encoded.Reader.OrcEncodedColumnBatch

Enclosing interface:

Reader

public static final class Reader.OrcEncodedColumnBatch
extends org.apache.hadoop.hive.common.io.encoded.EncodedColumnBatch<OrcBatchKey>

Implementation of EncodedColumnBatch for ORC.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hive.common.io.encoded.EncodedColumnBatch

org.apache.hadoop.hive.common.io.encoded.EncodedColumnBatch.ColumnStreamData

Field Summary

Fields

Modifier and Type	Field and Description
static int	ALL_RGS RG index indicating the data applies for all RGs (e.g.
protected List<org.apache.hadoop.hive.ql.exec.vector.ColumnVector>[]	columnVectors Same as columnData, but for the data that already comes as VRBs.
static int	MAX_DATA_STREAMS All the previous streams are data streams, this and the next ones are index streams.

Fields inherited from class org.apache.hadoop.hive.common.io.encoded.EncodedColumnBatch

batchKey, columnData, hasData

Constructor Summary

Constructors

Constructor and Description
OrcEncodedColumnBatch()

Method Summary

Modifier and Type	Method and Description
int	getColumnsWithDataCount()
List<org.apache.hadoop.hive.ql.exec.vector.ColumnVector>	getColumnVectors(int colIx)
boolean	hasVectors(int colIx)
void	init(Object fileKey, int stripeIx, int rgIx, int columnCount)
void	initColumnWithVectors(int colIx, List<org.apache.hadoop.hive.ql.exec.vector.ColumnVector> data)
void	initOrcColumn(int colIx)
void	reset()
protected void	resetColumnArrays(int columnCount)

Methods inherited from class org.apache.hadoop.hive.common.io.encoded.EncodedColumnBatch

getBatchKey, getColumnData, getTotalColCount, hasData, initColumn, setStreamData

Methods inherited from class java.lang.Object

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

Field Detail

ALL_RGS

public static final int ALL_RGS

RG index indicating the data applies for all RGs (e.g. a string dictionary).

See Also:

Constant Field Values

MAX_DATA_STREAMS

public static final int MAX_DATA_STREAMS

All the previous streams are data streams, this and the next ones are index streams. We assume the order will stay the same for backward compat.

columnVectors

protected List<org.apache.hadoop.hive.ql.exec.vector.ColumnVector>[] columnVectors

Same as columnData, but for the data that already comes as VRBs. The combination of the two contains all the necessary data,

Constructor Detail

OrcEncodedColumnBatch

public OrcEncodedColumnBatch()

Method Detail

init

public void init(Object fileKey,
                 int stripeIx,
                 int rgIx,
                 int columnCount)

initOrcColumn

public void initOrcColumn(int colIx)

reset

public void reset()

Overrides:

reset in class org.apache.hadoop.hive.common.io.encoded.EncodedColumnBatch<OrcBatchKey>

initColumnWithVectors

public void initColumnWithVectors(int colIx,
                                  List<org.apache.hadoop.hive.ql.exec.vector.ColumnVector> data)

resetColumnArrays

protected void resetColumnArrays(int columnCount)

Overrides:

resetColumnArrays in class org.apache.hadoop.hive.common.io.encoded.EncodedColumnBatch<OrcBatchKey>

hasVectors

public boolean hasVectors(int colIx)

getColumnVectors

public List<org.apache.hadoop.hive.ql.exec.vector.ColumnVector> getColumnVectors(int colIx)

getColumnsWithDataCount

public int getColumnsWithDataCount()