Trait StreamPlanNodeMetadata

pub trait StreamPlanNodeMetadata: PhysicalPlanRef {
    // Required methods
    fn stream_kind(&self) -> StreamKind;
    fn emit_on_window_close(&self) -> bool;
    fn watermark_columns(&self) -> &WatermarkColumns;
    fn columns_monotonicity(&self) -> &MonotonicityMap;

    // Provided method
    fn append_only(&self) -> bool { ... }
}

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 stream_kind(&self) -> StreamKind

fn emit_on_window_close(&self) -> bool

fn watermark_columns(&self) -> &WatermarkColumns

fn columns_monotonicity(&self) -> &MonotonicityMap

Provided Methods

fn append_only(&self) -> bool

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 + StreamPlanNodeMetadata + ?Sized> StreamPlanNodeMetadata for &'a T

where &'a T: PhysicalPlanRef,

fn stream_kind(&self) -> StreamKind

fn append_only(&self) -> bool

fn emit_on_window_close(&self) -> bool

fn watermark_columns(&self) -> &WatermarkColumns

fn columns_monotonicity(&self) -> &MonotonicityMap

Implementors

impl StreamPlanNodeMetadata for PlanBase<Stream>

impl StreamPlanNodeMetadata for StreamPlanRef

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