Struct LimitPushPastWindows 

pub struct LimitPushPastWindows;

This rule inspects ExecutionPlan’s attempting to find fetch limits that were not pushed down by LimitPushdown because BoundedWindowAggExecs were “in the way”. If the window is bounded by WindowFrameUnits::Rows then we calculate the adjustment needed to grow the limit and continue pushdown.

Implementations

impl LimitPushPastWindows

pub fn new() -> LimitPushPastWindows

Trait Implementations

impl Clone for LimitPushPastWindows

fn clone(&self) -> LimitPushPastWindows

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LimitPushPastWindows

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

Formats the value using the given formatter.

impl Default for LimitPushPastWindows

fn default() -> LimitPushPastWindows

Returns the “default value” for a type.

impl PhysicalOptimizerRule for LimitPushPastWindows

fn optimize( &self, original: 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.