Struct SamkhyaOptimizerRule 

pub struct SamkhyaOptimizerRule { /* private fields */ }

DataFusion adapter rule that bridges samkhya’s corrected statistics into the optimizer.

Implements both OptimizerRule (logical observe-only) and PhysicalOptimizerRule (physical validator). The physical pass is the visible integration point; the actual scan-wrapping that makes physical.statistics()?.num_rows reflect samkhya’s corrections is done by crate::SamkhyaTableProvider’s scan() at plan-construction time.

Register with both SessionStateBuilder::with_optimizer_rule and SessionStateBuilder::with_physical_optimizer_rule.

Implementations

impl SamkhyaOptimizerRule

pub fn new() -> Self

Create a new rule with zeroed counters.

pub fn arc() -> Arc<Self>

Wrap in an Arc for registration with SessionStateBuilder.

pub fn samkhya_leaves_seen(&self) -> usize

Number of SamkhyaStatsExec wrappers seen by the most recent physical-optimize pass.

Useful in tests to confirm the physical pass actually observed the wrappers installed by SamkhyaTableProvider::scan.

Trait Implementations

impl Clone for SamkhyaOptimizerRule

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SamkhyaOptimizerRule

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

Formats the value using the given formatter.

impl Default for SamkhyaOptimizerRule

fn default() -> SamkhyaOptimizerRule

Returns the “default value” for a type.

impl OptimizerRule for SamkhyaOptimizerRule

fn name(&self) -> &str

A human readable name for this optimizer rule

fn apply_order(&self) -> Option<ApplyOrder>

How should the rule be applied by the optimizer? See comments on ApplyOrder for details.

fn supports_rewrite(&self) -> bool

Does this rule support rewriting owned plans (rather than by reference)?

fn rewrite( &self, plan: LogicalPlan, _config: &dyn OptimizerConfig, ) -> Result<Transformed<LogicalPlan>>

Try to rewrite plan to an optimized form, returning Transformed::yes if the plan was rewritten and Transformed::no if it was not.

fn try_optimize( &self, _plan: &LogicalPlan, _config: &dyn OptimizerConfig, ) -> Result<Option<LogicalPlan>, DataFusionError>

👎Deprecated since 40.0.0:

please implement supports_rewrite and rewrite instead

Try and rewrite plan to an optimized form, returning None if the plan cannot be optimized by this rule.

impl PhysicalOptimizerRule for SamkhyaOptimizerRule

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 valid 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.

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

Rewrite plan to an optimized form