Struct RangeScanOperator 

pub struct RangeScanOperator { /* private fields */ }

Pull-based operator that emits node ids whose property value falls within a range. See the module docs for details.

Implementations

impl RangeScanOperator

pub fn new( store: Arc<dyn GraphStoreSearch>, property: impl Into<String>, min: Option<Value>, max: Option<Value>, min_inclusive: bool, max_inclusive: bool, chunk_capacity: usize, ) -> Self

Creates a range scan over store for the given property and bounds.

chunk_capacity is the number of rows per emitted DataChunk; the standard default in this codebase is 2048.

pub fn with_limit(self, limit: usize) -> Self

Sets a row-count cap that bounds the materialization step.

When set, the underlying iterator is consumed via take(limit), so blocks past the cap are never decoded. Wired by the planner in Phase 4e when a downstream LIMIT k is known statically.

pub fn limit(&self) -> Option<usize>

Returns the row-count cap set by with_limit, or None if no cap is in effect. Used by planner tests to verify LIMIT pushdown wired the cap.

pub fn with_label_filter(self, label: impl Into<String>) -> Self

Restricts the result to nodes carrying label.

Applied during materialization by intersecting the iterator’s output with store.nodes_by_label(label). Mirrors the eager find_nodes_in_range + nodes_by_label retain pattern that the planner used pre-Phase-4d.

pub fn with_transaction_context( self, epoch: EpochId, transaction_id: TransactionId, ) -> Self

Filters results by MVCC visibility at the given epoch and tx.

Applied during materialization via store.get_node_versioned. Required for any planner-emitted scan: the existing plan_range_filter always applies this filter, and the operator preserves that.

Trait Implementations

impl Operator for RangeScanOperator

fn next(&mut self) -> OperatorResult

Pulls the next batch of data. Returns None when exhausted.

fn reset(&mut self)

Resets to initial state so you can iterate again.

fn name(&self) -> &'static str

Returns a name for debugging/explain output.

fn into_any(self: Box<Self>) -> Box<dyn Any + Send>

Converts this boxed operator into Box<dyn Any> for type-based dispatch.