Struct datafusion_optimizer::analyzer::Analyzer

pub struct Analyzer {
    pub function_rewrites: Vec<Arc<dyn FunctionRewrite + Send + Sync>>,
    pub rules: Vec<Arc<dyn AnalyzerRule + Send + Sync>>,
}

A rule-based Analyzer.

An Analyzer transforms a LogicalPlan prior to the rest of the DataFusion optimization process.

Fields

function_rewrites: Vec<Arc<dyn FunctionRewrite + Send + Sync>>

Expr –> Function writes to apply prior to analysis passes

rules: Vec<Arc<dyn AnalyzerRule + Send + Sync>>

All rules to apply

Implementations

impl Analyzer

pub fn new() -> Self

Create a new analyzer using the recommended list of rules

pub fn with_rules(rules: Vec<Arc<dyn AnalyzerRule + Send + Sync>>) -> Self

Create a new analyzer with the given rules

pub fn add_function_rewrite( &mut self, rewrite: Arc<dyn FunctionRewrite + Send + Sync>, )

Add a function rewrite rule

pub fn function_rewrites(&self) -> &[Arc<dyn FunctionRewrite + Send + Sync>]

return the list of function rewrites in this analyzer

pub fn execute_and_check<F>( &self, plan: LogicalPlan, config: &ConfigOptions, observer: F, ) -> Result<LogicalPlan>

where F: FnMut(&LogicalPlan, &dyn AnalyzerRule),

Analyze the logical plan by applying analyzer rules, and do necessary check and fail the invalid plans

Trait Implementations

impl Clone for Analyzer

fn clone(&self) -> Analyzer

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Default for Analyzer

fn default() -> Self

Returns the “default value” for a type.