Trait StreamPlanRef

pub trait StreamPlanRef: PhysicalPlanRef {
    // Required methods
    fn append_only(&self) -> bool;
    fn emit_on_window_close(&self) -> bool;
    fn watermark_columns(&self) -> &FixedBitSet;
    fn columns_monotonicity(&self) -> &MonotonicityMap;
}

A subtrait of PhysicalPlanRef for stream plans.

Due to the lack of refactoring, all plan nodes currently implement this trait through super::PlanBase. One may still use this trait as a bound for accessing a stream plan, in contrast to GenericPlanRef or PhysicalPlanRef.

Required Methods

fn append_only(&self) -> bool

fn emit_on_window_close(&self) -> bool

fn watermark_columns(&self) -> &FixedBitSet

fn columns_monotonicity(&self) -> &MonotonicityMap

Object Safety

This trait is not object safe.

Implementations on Foreign Types

impl<'a, T: 'a + StreamPlanRef + ?Sized> StreamPlanRef for &'a T

where &'a T: PhysicalPlanRef,

fn append_only(&self) -> bool

fn emit_on_window_close(&self) -> bool

fn watermark_columns(&self) -> &FixedBitSet

fn columns_monotonicity(&self) -> &MonotonicityMap

Implementors

impl StreamPlanRef for PlanBaseRef<'_>

impl StreamPlanRef for PlanBase<Stream>

impl StreamPlanRef for PlanRef

Allow access to all fields defined in StreamPlanRef for the type-erased plan node.