Struct FileRange 

pub struct FileRange {
    context: FileRangeContextRef,
    row_group_idx: usize,
    row_selection: Option<RowSelection>,
}

A range of a parquet SST. Now it is a row group. We can read different file ranges in parallel.

Fields

context: FileRangeContextRef

Shared context.

row_group_idx: usize

Index of the row group in the SST.

row_selection: Option<RowSelection>

Row selection for the row group. None means all rows.

Implementations

impl FileRange

pub(crate) fn region_metadata(&self) -> &RegionMetadataRef

Returns the region metadata stored in this SST.

pub(crate) fn primary_key_range(&self) -> Option<(&[u8], &[u8])>

Returns encoded primary-key min/max statistics for this row group.

pub(crate) fn new( context: FileRangeContextRef, row_group_idx: usize, row_selection: Option<RowSelection>, ) -> Self

Creates a new FileRange.

fn select_all(&self) -> bool

Returns true if FileRange selects all rows in row group.

fn in_dynamic_filter_range(&self) -> bool

Performs pruning before reading the FileRange. It use latest dynamic filters with row group statistics to prune the range.

Returns false if the entire range is pruned and can be skipped.

pub async fn flat_reader( &self, selector: Option<TimeSeriesRowSelector>, fetch_metrics: Option<&ParquetFetchMetrics>, ) -> Result<Option<FlatPruneReader>>

Creates a flat reader that returns RecordBatch.

pub(crate) async fn primary_key_reader( &self, fetch_metrics: Option<&ParquetFetchMetrics>, ) -> Result<Option<BoxStream<'static, Result<RecordBatch>>>>

Creates a reader that returns only the encoded primary-key column.

The returned primary keys are compatible with the expected region metadata.

async fn primary_key_reader_inner( &self, fetch_metrics: Option<&ParquetFetchMetrics>, check_dynamic_filter: bool, ) -> Result<Option<BoxStream<'static, Result<RecordBatch>>>>

pub(crate) async fn reader_by_primary_key( &self, primary_key_filter: &mut dyn PrimaryKeyFilter, fetch_metrics: Option<&ParquetFetchMetrics>, ) -> Result<Option<FlatRowGroupReader>>

Builds a full-projection reader selected only by the provided encoded-PK filter and this range’s existing row selection.

This deliberately bypasses generic predicate prefiltering. The series pruner selected the row group independently, and simple predicates retained by the disabled prefilter plan are applied precisely before merge.

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

Returns the helper to compat batches.

pub(crate) fn compaction_projection_mapper( &self, ) -> Option<&CompactionProjectionMapper>

Returns the helper to project batches.

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

Filters a full-projection batch using this range’s precise filters.

pub(crate) fn pre_filter_mode(&self) -> PreFilterMode

Returns the precise-filter mode configured for this range.

pub(crate) fn file_handle(&self) -> &FileHandle

Returns the file handle of the file range.

Trait Implementations

impl Clone for FileRange

fn clone(&self) -> FileRange

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.