Class VectorizedArrowReader.ConstantVectorReader<T>
- java.lang.Object
-
- org.apache.iceberg.arrow.vectorized.VectorizedArrowReader
-
- org.apache.iceberg.arrow.vectorized.VectorizedArrowReader.ConstantVectorReader<T>
-
- Type Parameters:
T
- The constant value to use
- All Implemented Interfaces:
VectorizedReader<VectorHolder>
- Enclosing class:
- VectorizedArrowReader
public static class VectorizedArrowReader.ConstantVectorReader<T> extends VectorizedArrowReader
A Dummy Vector Reader which doesn't actually read files, instead it returns a dummy VectorHolder which indicates the constant value which should be used for this column.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.apache.iceberg.arrow.vectorized.VectorizedArrowReader
VectorizedArrowReader.ConstantVectorReader<T>, VectorizedArrowReader.DeletedVectorReader
-
-
Field Summary
-
Fields inherited from class org.apache.iceberg.arrow.vectorized.VectorizedArrowReader
DEFAULT_BATCH_SIZE
-
-
Constructor Summary
Constructors Constructor Description ConstantVectorReader(T value)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description VectorHolder
read(VectorHolder reuse, int numValsToRead)
Reads a batch of type @param <T> and of size numRowsvoid
setBatchSize(int batchSize)
void
setRowGroupInfo(org.apache.parquet.column.page.PageReadStore source, java.util.Map<org.apache.parquet.hadoop.metadata.ColumnPath,org.apache.parquet.hadoop.metadata.ColumnChunkMetaData> metadata, long rowPosition)
Sets the row group information to be used with this readerjava.lang.String
toString()
-
Methods inherited from class org.apache.iceberg.arrow.vectorized.VectorizedArrowReader
close, nulls, positions, positionsWithSetArrowValidityVector
-
-
-
-
Constructor Detail
-
ConstantVectorReader
public ConstantVectorReader(T value)
-
-
Method Detail
-
read
public VectorHolder read(VectorHolder reuse, int numValsToRead)
Description copied from interface:VectorizedReader
Reads a batch of type @param <T> and of size numRows- Specified by:
read
in interfaceVectorizedReader<T>
- Overrides:
read
in classVectorizedArrowReader
- Parameters:
reuse
- container for the last batch to be reused for next batchnumValsToRead
- number of rows to read- Returns:
- batch of records of type @param <T>
-
setRowGroupInfo
public void setRowGroupInfo(org.apache.parquet.column.page.PageReadStore source, java.util.Map<org.apache.parquet.hadoop.metadata.ColumnPath,org.apache.parquet.hadoop.metadata.ColumnChunkMetaData> metadata, long rowPosition)
Description copied from interface:VectorizedReader
Sets the row group information to be used with this reader- Specified by:
setRowGroupInfo
in interfaceVectorizedReader<T>
- Overrides:
setRowGroupInfo
in classVectorizedArrowReader
- Parameters:
source
- row group information for all the columnsmetadata
- map ofColumnPath
->ColumnChunkMetaData
for the row grouprowPosition
- the row group's row offset in the parquet file
-
toString
public java.lang.String toString()
- Overrides:
toString
in classVectorizedArrowReader
-
setBatchSize
public void setBatchSize(int batchSize)
- Specified by:
setBatchSize
in interfaceVectorizedReader<T>
- Overrides:
setBatchSize
in classVectorizedArrowReader
-
-