Struct RangeMeta

pub(crate) struct RangeMeta {
    pub(crate) time_range: FileTimeRange,
    pub(crate) indices: SmallVec<[SourceIndex; 2]>,
    pub(crate) row_group_indices: SmallVec<[RowGroupIndex; 2]>,
    pub(crate) num_rows: usize,
}

Meta data of a partition range. If the scanner is [UnorderedScan], each meta only has one row group or memtable. If the scanner is [SeqScan], each meta may have multiple row groups and memtables.

Fields

time_range: FileTimeRange

The time range of the range.

indices: SmallVec<[SourceIndex; 2]>

Indices to memtables or files.

row_group_indices: SmallVec<[RowGroupIndex; 2]>

Indices to memtable/file row groups that this range scans.

num_rows: usize

Estimated number of rows in the range. This can be 0 if the statistics are not available.

Implementations

impl RangeMeta

pub(crate) fn new_partition_range(&self, identifier: usize) -> PartitionRange

Creates a PartitionRange with specific identifier. It converts the inclusive max timestamp to exclusive end timestamp.

pub(crate) fn seq_scan_ranges( input: &ScanInput, compaction: bool, ) -> Vec<RangeMeta>

Creates a list of ranges from the input for seq scan. If compaction is true, it doesn’t split the ranges.

pub(crate) fn unordered_scan_ranges(input: &ScanInput) -> Vec<RangeMeta>

Creates a list of ranges from the input for unordered scan.

fn overlaps(&self, meta: &RangeMeta) -> bool

Returns true if the time range of given meta overlaps with the time range of this meta.

fn merge(&mut self, other: RangeMeta)

Merges given meta to this meta. It assumes that the time ranges overlap and they don’t have the same file or memtable index.

fn can_split_preserve_order(&self) -> bool

Returns true if we can split the range into multiple smaller ranges and still preserve the order for [SeqScan].

fn maybe_split(self, output: &mut Vec<RangeMeta>)

Splits the range if it can preserve the order.

fn push_unordered_mem_ranges( memtables: &[MemRangeBuilder], ranges: &mut Vec<RangeMeta>, )

fn push_unordered_file_ranges( num_memtables: usize, files: &[FileHandle], cache: &CacheStrategy, ranges: &mut Vec<RangeMeta>, )

fn push_seq_mem_ranges( memtables: &[MemRangeBuilder], ranges: &mut Vec<RangeMeta>, )

fn push_seq_file_ranges( num_memtables: usize, files: &[FileHandle], ranges: &mut Vec<RangeMeta>, )

Trait Implementations

impl Debug for RangeMeta

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl PartialEq for RangeMeta

fn eq(&self, other: &RangeMeta) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for RangeMeta