Uses of Interface
org.apache.flink.connector.file.src.util.Pool.Recycler
-
Packages that use Pool.Recycler Package Description org.apache.flink.connector.file.src.util org.apache.flink.formats.parquet org.apache.flink.orc -
-
Uses of Pool.Recycler in org.apache.flink.connector.file.src.util
Methods in org.apache.flink.connector.file.src.util that return Pool.Recycler Modifier and Type Method Description Pool.Recycler<T>
Pool. recycler()
Gets the recycler for this pool. -
Uses of Pool.Recycler in org.apache.flink.formats.parquet
Methods in org.apache.flink.formats.parquet with parameters of type Pool.Recycler Modifier and Type Method 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)
Constructors in org.apache.flink.formats.parquet with parameters of type Pool.Recycler Constructor Description ParquetReaderBatch(WritableColumnVector[] writableVectors, VectorizedColumnBatch columnarBatch, Pool.Recycler<ParquetVectorizedInputFormat.ParquetReaderBatch<T>> recycler)
-
Uses of Pool.Recycler in org.apache.flink.orc
Methods in org.apache.flink.orc with parameters of type Pool.Recycler Modifier and Type Method Description abstract AbstractOrcFileInputFormat.OrcReaderBatch<T,BatchT>
AbstractOrcFileInputFormat. createReaderBatch(SplitT split, OrcVectorizedBatchWrapper<BatchT> orcBatch, Pool.Recycler<AbstractOrcFileInputFormat.OrcReaderBatch<T,BatchT>> recycler, int batchSize)
Creates theAbstractOrcFileInputFormat.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.AbstractOrcFileInputFormat.OrcReaderBatch<RowData,BatchT>
OrcColumnarRowInputFormat. createReaderBatch(SplitT split, OrcVectorizedBatchWrapper<BatchT> orcBatch, Pool.Recycler<AbstractOrcFileInputFormat.OrcReaderBatch<RowData,BatchT>> recycler, int batchSize)
Constructors in org.apache.flink.orc with parameters of type Pool.Recycler Constructor Description OrcReaderBatch(OrcVectorizedBatchWrapper<BatchT> orcVectorizedRowBatch, Pool.Recycler<AbstractOrcFileInputFormat.OrcReaderBatch<T,BatchT>> recycler)
-