risingwave_frontend::optimizer::plan_visitor

Trait StreamPlanVisitor

pub trait StreamPlanVisitor {
    type Result;
    type DefaultBehavior: DefaultBehavior<Self::Result>;

Show 50 methods    // Required method
    fn default_behavior() -> Self::DefaultBehavior;

    // Provided methods
    fn visit_stream(&mut self, plan: PlanRef<Stream>) -> Self::Result { ... }
    fn visit_stream_project(&mut self, plan: &StreamProject) -> Self::Result { ... }
    fn visit_stream_filter(&mut self, plan: &StreamFilter) -> Self::Result { ... }
    fn visit_stream_table_scan(
        &mut self,
        plan: &StreamTableScan,
    ) -> Self::Result { ... }
    fn visit_stream_cdc_table_scan(
        &mut self,
        plan: &StreamCdcTableScan,
    ) -> Self::Result { ... }
    fn visit_stream_sink(&mut self, plan: &StreamSink) -> Self::Result { ... }
    fn visit_stream_source(&mut self, plan: &StreamSource) -> Self::Result { ... }
    fn visit_stream_source_scan(
        &mut self,
        plan: &StreamSourceScan,
    ) -> Self::Result { ... }
    fn visit_stream_hash_join(&mut self, plan: &StreamHashJoin) -> Self::Result { ... }
    fn visit_stream_exchange(&mut self, plan: &StreamExchange) -> Self::Result { ... }
    fn visit_stream_hash_agg(&mut self, plan: &StreamHashAgg) -> Self::Result { ... }
    fn visit_stream_simple_agg(
        &mut self,
        plan: &StreamSimpleAgg,
    ) -> Self::Result { ... }
    fn visit_stream_stateless_simple_agg(
        &mut self,
        plan: &StreamStatelessSimpleAgg,
    ) -> Self::Result { ... }
    fn visit_stream_materialize(
        &mut self,
        plan: &StreamMaterialize,
    ) -> Self::Result { ... }
    fn visit_stream_top_n(&mut self, plan: &StreamTopN) -> Self::Result { ... }
    fn visit_stream_hop_window(
        &mut self,
        plan: &StreamHopWindow,
    ) -> Self::Result { ... }
    fn visit_stream_delta_join(
        &mut self,
        plan: &StreamDeltaJoin,
    ) -> Self::Result { ... }
    fn visit_stream_expand(&mut self, plan: &StreamExpand) -> Self::Result { ... }
    fn visit_stream_dynamic_filter(
        &mut self,
        plan: &StreamDynamicFilter,
    ) -> Self::Result { ... }
    fn visit_stream_project_set(
        &mut self,
        plan: &StreamProjectSet,
    ) -> Self::Result { ... }
    fn visit_stream_group_top_n(
        &mut self,
        plan: &StreamGroupTopN,
    ) -> Self::Result { ... }
    fn visit_stream_union(&mut self, plan: &StreamUnion) -> Self::Result { ... }
    fn visit_stream_row_id_gen(&mut self, plan: &StreamRowIdGen) -> Self::Result { ... }
    fn visit_stream_dml(&mut self, plan: &StreamDml) -> Self::Result { ... }
    fn visit_stream_now(&mut self, plan: &StreamNow) -> Self::Result { ... }
    fn visit_stream_share(&mut self, plan: &StreamShare) -> Self::Result { ... }
    fn visit_stream_watermark_filter(
        &mut self,
        plan: &StreamWatermarkFilter,
    ) -> Self::Result { ... }
    fn visit_stream_temporal_join(
        &mut self,
        plan: &StreamTemporalJoin,
    ) -> Self::Result { ... }
    fn visit_stream_values(&mut self, plan: &StreamValues) -> Self::Result { ... }
    fn visit_stream_dedup(&mut self, plan: &StreamDedup) -> Self::Result { ... }
    fn visit_stream_eowc_over_window(
        &mut self,
        plan: &StreamEowcOverWindow,
    ) -> Self::Result { ... }
    fn visit_stream_eowc_sort(&mut self, plan: &StreamEowcSort) -> Self::Result { ... }
    fn visit_stream_over_window(
        &mut self,
        plan: &StreamOverWindow,
    ) -> Self::Result { ... }
    fn visit_stream_fs_fetch(&mut self, plan: &StreamFsFetch) -> Self::Result { ... }
    fn visit_stream_change_log(
        &mut self,
        plan: &StreamChangeLog,
    ) -> Self::Result { ... }
    fn visit_stream_global_approx_percentile(
        &mut self,
        plan: &StreamGlobalApproxPercentile,
    ) -> Self::Result { ... }
    fn visit_stream_local_approx_percentile(
        &mut self,
        plan: &StreamLocalApproxPercentile,
    ) -> Self::Result { ... }
    fn visit_stream_row_merge(&mut self, plan: &StreamRowMerge) -> Self::Result { ... }
    fn visit_stream_as_of_join(&mut self, plan: &StreamAsOfJoin) -> Self::Result { ... }
    fn visit_stream_sync_log_store(
        &mut self,
        plan: &StreamSyncLogStore,
    ) -> Self::Result { ... }
    fn visit_stream_materialized_exprs(
        &mut self,
        plan: &StreamMaterializedExprs,
    ) -> Self::Result { ... }
    fn visit_stream_vector_index_write(
        &mut self,
        plan: &StreamVectorIndexWrite,
    ) -> Self::Result { ... }
    fn visit_stream_vector_index_lookup_join(
        &mut self,
        plan: &StreamVectorIndexLookupJoin,
    ) -> Self::Result { ... }
    fn visit_stream_upstream_sink_union(
        &mut self,
        plan: &StreamUpstreamSinkUnion,
    ) -> Self::Result { ... }
    fn visit_stream_locality_provider(
        &mut self,
        plan: &StreamLocalityProvider,
    ) -> Self::Result { ... }
    fn visit_stream_eowc_gap_fill(
        &mut self,
        plan: &StreamEowcGapFill,
    ) -> Self::Result { ... }
    fn visit_stream_gap_fill(&mut self, plan: &StreamGapFill) -> Self::Result { ... }
    fn visit_stream_iceberg_with_pk_index_writer(
        &mut self,
        plan: &StreamIcebergWithPkIndexWriter,
    ) -> Self::Result { ... }
    fn visit_stream_iceberg_with_pk_index_dv_merger(
        &mut self,
        plan: &StreamIcebergWithPkIndexDvMerger,
    ) -> Self::Result { ... }
}