Package | Description |
---|---|
org.apache.flink.formats.parquet | |
org.apache.flink.formats.parquet.vector | |
org.apache.flink.orc | |
org.apache.flink.orc.vector | |
org.apache.flink.table.data |
Modifier and Type | Field and Description |
---|---|
protected VectorizedColumnBatch |
ParquetVectorizedInputFormat.ParquetReaderBatch.columnarBatch |
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 |
---|---|
VectorizedColumnBatch |
ColumnBatchFactory.create(SplitT split,
ColumnVector[] vectors) |
VectorizedColumnBatch |
ParquetColumnarRowSplitReader.ColumnBatchGenerator.generate(ColumnVector[] readVectors) |
Modifier and Type | Method and Description |
---|---|
VectorizedColumnBatch |
OrcColumnarRowSplitReader.ColumnBatchGenerator.generate(BATCH rowBatch) |
Modifier and Type | Method and Description |
---|---|
VectorizedColumnBatch |
ColumnBatchFactory.create(SplitT splitT,
BatchT rowBatch) |
Modifier and Type | Method and Description |
---|---|
void |
ColumnarRowData.setVectorizedColumnBatch(VectorizedColumnBatch vectorizedColumnBatch) |
Constructor and Description |
---|
ColumnarRowData(VectorizedColumnBatch vectorizedColumnBatch) |
ColumnarRowData(VectorizedColumnBatch vectorizedColumnBatch,
int rowId) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.