Type Alias StreamPlanRef

pub type StreamPlanRef = PlanRef<Stream>;

Aliased Type

pub struct StreamPlanRef(Rc<dyn StreamPlanNode>);

Tuple Fields

0: Rc<dyn StreamPlanNode>

Implementations

impl StreamPlanRef

pub fn enforce_concrete_distribution(self) -> Self

Eliminate SomeShard distribution by using the stream key as the distribution key to enforce the current plan to have a known distribution key.

Trait Implementations

impl PhysicalPlanRef for StreamPlanRef

fn distribution(&self) -> &Distribution

impl StreamPlanNodeMetadata for StreamPlanRef

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

fn stream_kind(&self) -> StreamKind

fn emit_on_window_close(&self) -> bool

fn watermark_columns(&self) -> &WatermarkColumns

fn columns_monotonicity(&self) -> &MonotonicityMap

fn append_only(&self) -> bool