Struct PushdownOptimizer

pub struct PushdownOptimizer { /* private fields */ }

PushdownOptimizer is a physical optimizer rule that pushes down filters to the liquid cache server.

Implementations

impl PushdownOptimizer

pub fn new( cache_server: String, cache_mode: CacheMode, object_stores: Vec<(ObjectStoreUrl, HashMap<String, String>)>, ) -> Self

Create a new PushdownOptimizer

Arguments

• cache_server - The address of the liquid cache server
• cache_mode - The cache mode to use

Returns

Trait Implementations

impl Debug for PushdownOptimizer

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

Formats the value using the given formatter.

impl PhysicalOptimizerRule for PushdownOptimizer

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