Trait datafusion::optimizer::OptimizerRule

pub trait OptimizerRule {
    // Required methods
    fn try_optimize(
        &self,
        plan: &LogicalPlan,
        config: &dyn OptimizerConfig
    ) -> Result<Option<LogicalPlan>, DataFusionError>;
    fn name(&self) -> &str;

    // Provided methods
    fn apply_order(&self) -> Option<ApplyOrder> { ... }
    fn supports_rewrite(&self) -> bool { ... }
    fn rewrite(
        &self,
        _plan: LogicalPlan,
        _config: &dyn OptimizerConfig
    ) -> Result<Transformed<LogicalPlan>, DataFusionError> { ... }
}

OptimizerRules transforms one LogicalPlan into another which computes the same results, but in a potentially more efficient way. If there are no suitable transformations for the input plan, the optimizer should simply return it unmodified.

To change the semantics of a LogicalPlan, see AnalyzerRule

Use SessionState::add_optimizer_rule to register additional OptimizerRules.

Required Methods

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

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

Note this API will be deprecated in the future as it requires cloneing the input plan, which can be expensive. OptimizerRules should implement Self::rewrite instead.

fn name(&self) -> &str

A human readable name for this optimizer rule

Provided Methods

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

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

If returns None, the default, the rule must handle recursion itself

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>, DataFusionError>

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

Note: this function is only called if Self::supports_rewrite returns true. Otherwise the Optimizer calls Self::try_optimize

Implementors

impl OptimizerRule for CommonSubexprEliminate

impl OptimizerRule for DecorrelatePredicateSubquery

impl OptimizerRule for EliminateCrossJoin

Attempt to reorder join to eliminate cross joins to inner joins. for queries: ‘select … from a, b where a.x = b.y and b.xx = 100;’ ‘select … from a, b where (a.x = b.y and b.xx = 100) or (a.x = b.y and b.xx = 200);’ ‘select … from a, b, c where (a.x = b.y and b.xx = 100 and a.z = c.z) or (a.x = b.y and b.xx = 200 and a.z=c.z);’ ‘select … from a, b where a.x > b.y’ For above queries, the join predicate is available in filters and they are moved to join nodes appropriately This fix helps to improve the performance of TPCH Q19. issue#78

impl OptimizerRule for EliminateDuplicatedExpr

impl OptimizerRule for EliminateFilter

impl OptimizerRule for EliminateJoin

impl OptimizerRule for EliminateLimit

impl OptimizerRule for EliminateNestedUnion

impl OptimizerRule for EliminateOneUnion

impl OptimizerRule for EliminateOuterJoin

Attempt to eliminate outer joins.

impl OptimizerRule for ExtractEquijoinPredicate

impl OptimizerRule for FilterNullJoinKeys

impl OptimizerRule for OptimizeProjections

impl OptimizerRule for PropagateEmptyRelation

impl OptimizerRule for PushDownFilter

impl OptimizerRule for PushDownLimit

Push down Limit.

impl OptimizerRule for ReplaceDistinctWithAggregate

impl OptimizerRule for RewriteDisjunctivePredicate

impl OptimizerRule for ScalarSubqueryToJoin

impl OptimizerRule for SimplifyExpressions

impl OptimizerRule for SingleDistinctToGroupBy

impl OptimizerRule for UnwrapCastInComparison