public interface VectorizedReader<T>
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) |
T read(int numRows)
numRows
- number of rows to readvoid setRowGroupInfo(org.apache.parquet.column.page.PageReadStore pages, java.util.Map<org.apache.parquet.hadoop.metadata.ColumnPath,org.apache.parquet.hadoop.metadata.ColumnChunkMetaData> metadata)
pages
- row group information for all the columnsmetadata
- map of ColumnPath
-> ColumnChunkMetaData
for the row groupvoid reuseContainers(boolean reuse)
void close()