org.apache.iceberg.parquet

Interface VectorizedReader<T>

All Known Implementing Classes:

VectorizedArrowReader

public interface VectorizedReader<T>

Interface for vectorized Iceberg readers.

Method Summary

Modifier and Type	Method and Description
void	close() Release any resources allocated
T	read(int numRows) Reads a batch of type @param <T> and of size numRows
void	reuseContainers(boolean reuse) Set up the reader to reuse the underlying containers used for storing batches
void	setRowGroupInfo(org.apache.parquet.column.page.PageReadStore pages, java.util.Map<org.apache.parquet.hadoop.metadata.ColumnPath,org.apache.parquet.hadoop.metadata.ColumnChunkMetaData> metadata)

Method Detail

read

T read(int numRows)

Reads a batch of type @param <T> and of size numRows

Parameters:

numRows - number of rows to read

Returns:

batch of records of type @param <T>

setRowGroupInfo

void setRowGroupInfo(org.apache.parquet.column.page.PageReadStore pages,
                     java.util.Map<org.apache.parquet.hadoop.metadata.ColumnPath,org.apache.parquet.hadoop.metadata.ColumnChunkMetaData> metadata)

Parameters:

pages - row group information for all the columns

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

reuseContainers

void reuseContainers(boolean reuse)

Set up the reader to reuse the underlying containers used for storing batches

close

void close()

Release any resources allocated