Struct FileRangeContext 

pub(crate) struct FileRangeContext {
    reader_builder: RowGroupReaderBuilder,
    base: RangeBase,
}

Context shared by ranges of the same parquet SST.

Fields

reader_builder: RowGroupReaderBuilder

Row group reader builder for the file.

base: RangeBase

Base of the context.

Implementations

impl FileRangeContext

pub(crate) fn new( reader_builder: RowGroupReaderBuilder, base: RangeBase, ) -> Self

Creates a new FileRangeContext.

pub(crate) fn file_path(&self) -> &str

Returns the path of the file to read.

pub(crate) fn filters(&self) -> &[SimpleFilterContext]

Returns filters pushed down.

pub(crate) fn has_partition_filter(&self) -> bool

Returns true if a partition filter is configured.

pub(crate) fn read_format(&self) -> &ReadFormat

Returns the format helper.

pub(crate) fn reader_builder(&self) -> &RowGroupReaderBuilder

Returns the reader builder.

pub(crate) fn compat_batch(&self) -> Option<&CompatBatch>

Returns the helper to compat batches.

pub(crate) fn set_compat_batch(&mut self, compat: Option<CompatBatch>)

Sets the CompatBatch to the context.

pub(crate) fn precise_filter( &self, input: Batch, skip_fields: bool, ) -> Result<Option<Batch>>

TRY THE BEST to perform pushed down predicate precisely on the input batch. Return the filtered batch. If the entire batch is filtered out, return None. If a partition expr filter is configured, it is also applied.

pub(crate) fn precise_filter_flat( &self, input: RecordBatch, skip_fields: bool, ) -> Result<Option<RecordBatch>>

Filters the input RecordBatch by the pushed down predicate and returns RecordBatch. If a partition expr filter is configured, it is also applied.

pub(crate) fn should_skip_fields(&self, row_group_idx: usize) -> bool

Determines whether to skip field filters based on PreFilterMode and row group delete status.

pub(crate) fn contains_delete(&self, row_group_index: usize) -> Result<bool>

pub(crate) fn memory_size(&self) -> usize

Returns the estimated memory size of this context. Mainly accounts for the parquet metadata size.