Module projection_pushdown 

This file implements the ProjectionPushdown physical optimization rule. The function remove_unnecessary_projections tries to push down all projections one by one if the operator below is amenable to this. If a projection reaches a source, it can even disappear from the plan entirely.

Structs

JoinFilterRewriter 🔒

Implements the push-down machinery.

ProjectionPushdown

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

Functions

is_volatile_expression_tree 🔒

minimize_join_filter 🔒

Creates a new JoinFilter and tries to minimize the internal schema.

try_push_down_join_filter 🔒

Tries to push down parts of the filter.

try_push_down_projection 🔒

Tries to push down parts of expr into the join_side.