Package | Description |
---|---|
org.apache.flink.connector.file.src.util | |
org.apache.flink.formats.parquet | |
org.apache.flink.orc |
Modifier and Type | Method and Description |
---|---|
Pool.Recycler<T> |
Pool.recycler()
Gets the recycler for this pool.
|
Modifier and Type | Method and Description |
---|---|
protected ParquetVectorizedInputFormat.ParquetReaderBatch<RowData> |
ParquetColumnarRowInputFormat.createReaderBatch(WritableColumnVector[] writableVectors,
VectorizedColumnBatch columnarBatch,
Pool.Recycler<ParquetVectorizedInputFormat.ParquetReaderBatch<RowData>> recycler) |
protected abstract ParquetVectorizedInputFormat.ParquetReaderBatch<T> |
ParquetVectorizedInputFormat.createReaderBatch(WritableColumnVector[] writableVectors,
VectorizedColumnBatch columnarBatch,
Pool.Recycler<ParquetVectorizedInputFormat.ParquetReaderBatch<T>> recycler) |
Constructor and Description |
---|
ParquetReaderBatch(WritableColumnVector[] writableVectors,
VectorizedColumnBatch columnarBatch,
Pool.Recycler<ParquetVectorizedInputFormat.ParquetReaderBatch<T>> recycler) |
Modifier and Type | Method and Description |
---|---|
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) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.