Struct AdaptivePipelineExecutor 

pub struct AdaptivePipelineExecutor { /* private fields */ }

High-level adaptive pipeline that executes a pull-based operator with cardinality tracking using push-based infrastructure.

This bridges the pull-based planner output with push-based execution:

1. Wraps the pull operator as an OperatorSource
2. Uses CardinalityTrackingSink to track output cardinality
3. Provides adaptive feedback through AdaptiveContext

Example

use grafeo_core::execution::adaptive::AdaptivePipelineExecutor;

let executor = AdaptivePipelineExecutor::new(operator, adaptive_context);
let (chunks, summary) = executor.execute()?;

Implementations

impl AdaptivePipelineExecutor

pub fn new(operator: Box<dyn Operator>, context: AdaptiveContext) -> Self

Creates a new adaptive pipeline executor.

Arguments

• operator - The pull-based operator to execute
• context - Adaptive context with cardinality estimates

pub fn with_config( operator: Box<dyn Operator>, context: AdaptiveContext, config: AdaptivePipelineConfig, ) -> Self

Creates an executor with custom configuration.

pub fn execute(self) -> Result<(Vec<DataChunk>, AdaptiveSummary), OperatorError>

Executes the pipeline and returns collected chunks with adaptive summary.

Returns

A tuple of (collected DataChunks, adaptive execution summary).

Errors

Returns an error if execution fails.

pub fn execute_collecting( self, ) -> Result<(Vec<DataChunk>, AdaptiveSummary), OperatorError>

Executes and collects all results into DataChunks.

This is a simpler interface that handles chunk collection internally.

pub fn context(&self) -> &SharedAdaptiveContext

Returns a reference to the shared context for external monitoring.