Struct LocalModeOptimizer 

pub struct LocalModeOptimizer { /* private fields */ }

Physical optimizer rule for local mode liquid cache

This optimizer rewrites DataSourceExec nodes that read Parquet files to use LiquidParquetSource instead of the default ParquetSource

Implementations

impl LocalModeOptimizer

pub fn new(cache: LiquidCacheParquetRef, eager_shredding: bool) -> Self

Create an optimizer with an existing cache instance

pub fn with_cache(cache: LiquidCacheParquetRef) -> Self

Create an optimizer with an existing cache instance

Trait Implementations

impl Debug for LocalModeOptimizer

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

Formats the value using the given formatter.

impl PhysicalOptimizerRule for LocalModeOptimizer

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

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.