org.apache.iceberg.arrow.vectorized

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 and Description
ConstantVectorReader(Types.NestedField icebergField, T value)

Method Summary

Modifier and Type	Method and Description
VectorHolder	read(VectorHolder reuse, int numValsToRead) Reads a batch of type @param <T> and of size numRows
void	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 reader
java.lang.String	toString()

Methods inherited from class org.apache.iceberg.arrow.vectorized.VectorizedArrowReader

close, icebergField, nulls, positions, positionsWithSetArrowValidityVector

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ConstantVectorReader

public ConstantVectorReader(Types.NestedField icebergField,
                            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 interface VectorizedReader<VectorHolder>

Overrides:

read in class VectorizedArrowReader

Parameters:

reuse - container for the last batch to be reused for next batch

numValsToRead - 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 interface VectorizedReader<VectorHolder>

Overrides:

setRowGroupInfo in class VectorizedArrowReader

Parameters:

source - row group information for all the columns

metadata - map of ColumnPath -> ColumnChunkMetaData for the row group

rowPosition - the row group's row offset in the parquet file

toString

public java.lang.String toString()

Overrides:

toString in class VectorizedArrowReader

setBatchSize

public void setBatchSize(int batchSize)

Specified by:

setBatchSize in interface VectorizedReader<VectorHolder>

Overrides:

setBatchSize in class VectorizedArrowReader