Trait StreamNode

pub trait StreamNode {
    // Required method
    fn to_stream_prost_body(
        &self,
        state: &mut BuildFragmentGraphState,
    ) -> NodeBody;
}

Required Methods

fn to_stream_prost_body(&self, state: &mut BuildFragmentGraphState) -> NodeBody

Implementors

impl StreamNode for StreamAsOfJoin

impl StreamNode for StreamCdcTableScan

impl StreamNode for StreamChangeLog

impl StreamNode for StreamDedup

impl StreamNode for StreamDml

impl StreamNode for StreamDynamicFilter

impl StreamNode for StreamEowcOverWindow

impl StreamNode for StreamExchange

impl StreamNode for StreamExpand

impl StreamNode for StreamFilter

impl StreamNode for StreamFsFetch

impl StreamNode for StreamGlobalApproxPercentile

impl StreamNode for StreamGroupTopN

impl StreamNode for StreamHashAgg

impl StreamNode for StreamHashJoin

impl StreamNode for StreamHopWindow

impl StreamNode for StreamLocalApproxPercentile

impl StreamNode for StreamMaterialize

impl StreamNode for StreamNow

impl StreamNode for StreamOverWindow

impl StreamNode for StreamProject

impl StreamNode for StreamProjectSet

impl StreamNode for StreamRowIdGen

impl StreamNode for StreamRowMerge

impl StreamNode for StreamShare

impl StreamNode for StreamSimpleAgg

impl StreamNode for StreamSink

impl StreamNode for StreamEowcSort

impl StreamNode for StreamSource

impl StreamNode for StreamSourceScan

impl StreamNode for StreamStatelessSimpleAgg

impl StreamNode for StreamTableScan

impl StreamNode for StreamTopN

impl StreamNode for StreamUnion

impl StreamNode for StreamValues

impl StreamNode for StreamWatermarkFilter