Package | Description |
---|---|
org.apache.flink.orc | |
org.apache.flink.orc.nohive.vector | |
org.apache.flink.orc.shim | |
org.apache.flink.orc.vector |
Modifier and Type | Field and Description |
---|---|
protected OrcVectorizedBatchWrapper<BATCH> |
OrcSplitReader.rowBatchWrapper |
Modifier and Type | Method and Description |
---|---|
OrcVectorizedBatchWrapper<BatchT> |
AbstractOrcFileInputFormat.OrcReaderBatch.orcVectorizedRowBatch()
Gets the ORC VectorizedRowBatch structure from this batch.
|
Modifier and Type | Method and Description |
---|---|
abstract BulkFormat.RecordIterator<T> |
AbstractOrcFileInputFormat.OrcReaderBatch.convertAndGetIterator(OrcVectorizedBatchWrapper<BatchT> orcVectorizedRowBatch,
long startingOffset)
Converts the ORC VectorizedRowBatch into the result structure and returns an iterator
over the entries.
|
AbstractOrcFileInputFormat.OrcReaderBatch<RowData,BatchT> |
OrcColumnarRowInputFormat.createReaderBatch(SplitT split,
OrcVectorizedBatchWrapper<BatchT> orcBatch,
Pool.Recycler<AbstractOrcFileInputFormat.OrcReaderBatch<RowData,BatchT>> recycler,
int batchSize) |
abstract AbstractOrcFileInputFormat.OrcReaderBatch<T,BatchT> |
AbstractOrcFileInputFormat.createReaderBatch(SplitT split,
OrcVectorizedBatchWrapper<BatchT> orcBatch,
Pool.Recycler<AbstractOrcFileInputFormat.OrcReaderBatch<T,BatchT>> recycler,
int batchSize)
Creates the
AbstractOrcFileInputFormat.OrcReaderBatch structure, which is responsible for holding the data
structures that hold the batch data (column vectors, row arrays, ...) and the batch
conversion from the ORC representation to the result format. |
Constructor and Description |
---|
OrcReaderBatch(OrcVectorizedBatchWrapper<BatchT> orcVectorizedRowBatch,
Pool.Recycler<AbstractOrcFileInputFormat.OrcReaderBatch<T,BatchT>> recycler) |
Modifier and Type | Class and Description |
---|---|
class |
OrcNoHiveBatchWrapper
Wrap
VectorizedRowBatch orc batch. |
Modifier and Type | Method and Description |
---|---|
OrcVectorizedBatchWrapper<BATCH> |
OrcShim.createBatchWrapper(org.apache.orc.TypeDescription schema,
int batchSize) |
Modifier and Type | Class and Description |
---|---|
class |
HiveOrcBatchWrapper
Wrap
VectorizedRowBatch hive orc batch. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.