Struct StreamingPhysicalValidator 

pub struct StreamingPhysicalValidator { /* private fields */ }

Validates that a physical plan is safe for streaming execution.

Detects pipeline-breaking operators (Sort, Final Aggregate) on unbounded inputs and rejects or warns depending on configuration.

Implementations

impl StreamingPhysicalValidator

pub fn new(mode: StreamingValidatorMode) -> Self

Creates a new validator with the given mode.

Trait Implementations

impl Debug for StreamingPhysicalValidator

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

Formats the value using the given formatter.

impl PhysicalOptimizerRule for StreamingPhysicalValidator

fn optimize( &self, plan: Arc<dyn ExecutionPlan>, _config: &ConfigOptions, ) -> Result<Arc<dyn ExecutionPlan>>

Rewrite plan to an optimized form

fn name(&self) -> &str

A human readable name for this optimizer rule

fn schema_check(&self) -> bool

A flag to indicate whether the physical planner should validate that the rule will not change the schema of the plan after the rewriting. Some of the optimization rules might change the nullable properties of the schema and should disable the schema check.