Struct CardinalityTrackingOperator 

pub struct CardinalityTrackingOperator { /* private fields */ }

A wrapper operator that tracks cardinality and reports to an adaptive context.

This wraps any PushOperator and counts the rows flowing through it, reporting the count to the adaptive context.

Implementations

impl CardinalityTrackingOperator

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

Creates a new tracking wrapper.

pub fn current_count(&self) -> u64

Returns the current row count.

Trait Implementations

impl PushOperator for CardinalityTrackingOperator

fn push( &mut self, chunk: DataChunk, sink: &mut dyn Sink, ) -> Result<bool, OperatorError>

Process an incoming chunk and push results to the sink.

fn finalize(&mut self, sink: &mut dyn Sink) -> Result<(), OperatorError>

Called when all input has been processed.

fn preferred_chunk_size(&self) -> ChunkSizeHint

Hint for preferred chunk size.

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

Name of this operator for debugging.