Struct CardinalityTrackingWrapper 

pub struct CardinalityTrackingWrapper { /* private fields */ }

A wrapper that tracks cardinality for pull-based operators.

This wraps any Operator and counts the rows flowing through it, reporting the count to the adaptive context. Use this for integrating adaptive execution with the standard pull-based executor.

Implementations

impl CardinalityTrackingWrapper

pub fn new( inner: Box<dyn Operator>, operator_id: &str, context: SharedAdaptiveContext, ) -> Self

Creates a new tracking wrapper for a pull-based operator.

pub fn current_count(&self) -> u64

Returns the current row count.

Trait Implementations

impl Drop for CardinalityTrackingWrapper

fn drop(&mut self)

Executes the destructor for this type.

impl Operator for CardinalityTrackingWrapper

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.