Trait StreamPlanRef

pub trait StreamPlanRef: PhysicalPlanRef {
    // Required methods
    fn append_only(&self) -> bool;
    fn emit_on_window_close(&self) -> bool;
    fn watermark_columns(&self) -> &WatermarkColumns;
    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) -> &WatermarkColumns

fn columns_monotonicity(&self) -> &MonotonicityMap

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so 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) -> &WatermarkColumns

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.