Struct DataRequestBuilder 

pub(super) struct DataRequestBuilder<'a> {
    row_group_idx: usize,
    row_count: usize,
    batch_size: usize,
    parquet_metadata: &'a ParquetMetaData,
    projection: &'a ProjectionMask,
    selection: Option<&'a RowSelection>,
    cache_projection: Option<&'a ProjectionMask>,
    column_chunks: Option<Vec<Option<Arc<ColumnChunkData>>>>,
}

Builder for DataRequest

Fields

row_group_idx: usize

The row group index

row_count: usize

The number of rows in the row group

batch_size: usize

The batch size to read

parquet_metadata: &'a ParquetMetaData

The parquet metadata

projection: &'a ProjectionMask

The projection mask (which columns to read)

selection: Option<&'a RowSelection>

Optional row selection to apply

cache_projection: Option<&'a ProjectionMask>

Optional projection mask if using RowGroupCache for caching decoded columns.

column_chunks: Option<Vec<Option<Arc<ColumnChunkData>>>>

Any previously read column chunks

Implementations

impl<'a> DataRequestBuilder<'a>

pub(super) fn new( row_group_idx: usize, row_count: usize, batch_size: usize, parquet_metadata: &'a ParquetMetaData, projection: &'a ProjectionMask, ) -> Self

pub(super) fn with_selection(self, selection: Option<&'a RowSelection>) -> Self

Set an optional row selection to apply

pub(super) fn with_cache_projection( self, cache_projection: Option<&'a ProjectionMask>, ) -> Self

set columns to cache, if any

pub(super) fn with_column_chunks( self, column_chunks: Option<Vec<Option<Arc<ColumnChunkData>>>>, ) -> Self

Provide any previously read column chunks

pub(crate) fn build(self) -> DataRequest