Struct ProjectionPushdown 

pub struct ProjectionPushdown {}

This rule inspects ProjectionExec’s in the given physical plan and tries to remove or swap with its child.

Furthermore, tries to push down projections from nested loop join filters that only depend on one side of the join. By pushing these projections down, functions that only depend on one side of the join must be evaluated for the cartesian product of the two sides.

Implementations

impl ProjectionPushdown

pub fn new() -> ProjectionPushdown

Trait Implementations

impl Debug for ProjectionPushdown

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

Formats the value using the given formatter.

impl Default for ProjectionPushdown

fn default() -> ProjectionPushdown

Returns the “default value” for a type.

impl PhysicalOptimizerRule for ProjectionPushdown

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.