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(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, 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(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