Struct AdaptiveCheckpoint 

pub struct AdaptiveCheckpoint {
    pub id: String,
    pub after_operator: usize,
    pub estimated_cardinality: f64,
    pub actual_rows: u64,
    pub triggered: bool,
}

A checkpoint during adaptive execution where plan switching can occur.

Checkpoints are placed at strategic points in the pipeline (typically after filters or joins) where switching to a new plan makes sense.

Fields

id: String

Unique identifier for this checkpoint.

after_operator: usize

Operator index in the pipeline (after which this checkpoint occurs).

estimated_cardinality: f64

Estimated cardinality at this point.

actual_rows: u64

Actual rows seen so far.

triggered: bool

Whether this checkpoint has triggered re-optimization.

Implementations

impl AdaptiveCheckpoint

pub fn new(id: &str, after_operator: usize, estimated: f64) -> Self

Creates a new checkpoint.

pub fn record_rows(&mut self, count: u64)

Records rows passing through this checkpoint.

pub fn exceeds_threshold(&self, threshold: f64, min_rows: u64) -> bool

Checks if deviation exceeds threshold.

Trait Implementations

impl Debug for AdaptiveCheckpoint

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

Formats the value using the given formatter.