public static final class Reader.OrcEncodedColumnBatch extends org.apache.hadoop.hive.common.io.encoded.EncodedColumnBatch<OrcBatchKey>
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.
|
Constructor and Description |
---|
OrcEncodedColumnBatch() |
Modifier and Type | Method and Description |
---|---|
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) |
public static final int ALL_RGS
public static final int MAX_DATA_STREAMS
protected List<org.apache.hadoop.hive.ql.exec.vector.ColumnVector>[] columnVectors
public void init(Object fileKey, int stripeIx, int rgIx, int columnCount)
public void initOrcColumn(int colIx)
public void reset()
reset
in class org.apache.hadoop.hive.common.io.encoded.EncodedColumnBatch<OrcBatchKey>
public void initColumnWithVectors(int colIx, List<org.apache.hadoop.hive.ql.exec.vector.ColumnVector> data)
protected void resetColumnArrays(int columnCount)
resetColumnArrays
in class org.apache.hadoop.hive.common.io.encoded.EncodedColumnBatch<OrcBatchKey>
public boolean hasVectors(int colIx)
public List<org.apache.hadoop.hive.ql.exec.vector.ColumnVector> getColumnVectors(int colIx)
Copyright © 2021 The Apache Software Foundation. All rights reserved.