Trait PlanVisitor

pub trait PlanVisitor {
    type Result: Default;
    type DefaultBehavior: DefaultBehavior<Self::Result>;

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

    // Provided methods
    fn visit(&mut self, plan: PlanRef) -> Self::Result { ... }
    fn visit_logical_agg(&mut self, plan: &LogicalAgg) -> Self::Result { ... }
    fn visit_logical_apply(&mut self, plan: &LogicalApply) -> Self::Result { ... }
    fn visit_logical_filter(&mut self, plan: &LogicalFilter) -> Self::Result { ... }
    fn visit_logical_project(&mut self, plan: &LogicalProject) -> Self::Result { ... }
    fn visit_logical_scan(&mut self, plan: &LogicalScan) -> Self::Result { ... }
    fn visit_logical_cdc_scan(&mut self, plan: &LogicalCdcScan) -> Self::Result { ... }
    fn visit_logical_sys_scan(&mut self, plan: &LogicalSysScan) -> Self::Result { ... }
    fn visit_logical_source(&mut self, plan: &LogicalSource) -> Self::Result { ... }
    fn visit_logical_insert(&mut self, plan: &LogicalInsert) -> Self::Result { ... }
    fn visit_logical_delete(&mut self, plan: &LogicalDelete) -> Self::Result { ... }
    fn visit_logical_update(&mut self, plan: &LogicalUpdate) -> Self::Result { ... }
    fn visit_logical_join(&mut self, plan: &LogicalJoin) -> Self::Result { ... }
    fn visit_logical_values(&mut self, plan: &LogicalValues) -> Self::Result { ... }
    fn visit_logical_limit(&mut self, plan: &LogicalLimit) -> Self::Result { ... }
    fn visit_logical_top_n(&mut self, plan: &LogicalTopN) -> Self::Result { ... }
    fn visit_logical_hop_window(
        &mut self,
        plan: &LogicalHopWindow,
    ) -> Self::Result { ... }
    fn visit_logical_table_function(
        &mut self,
        plan: &LogicalTableFunction,
    ) -> Self::Result { ... }
    fn visit_logical_multi_join(
        &mut self,
        plan: &LogicalMultiJoin,
    ) -> Self::Result { ... }
    fn visit_logical_expand(&mut self, plan: &LogicalExpand) -> Self::Result { ... }
    fn visit_logical_project_set(
        &mut self,
        plan: &LogicalProjectSet,
    ) -> Self::Result { ... }
    fn visit_logical_union(&mut self, plan: &LogicalUnion) -> Self::Result { ... }
    fn visit_logical_over_window(
        &mut self,
        plan: &LogicalOverWindow,
    ) -> Self::Result { ... }
    fn visit_logical_share(&mut self, plan: &LogicalShare) -> Self::Result { ... }
    fn visit_logical_now(&mut self, plan: &LogicalNow) -> Self::Result { ... }
    fn visit_logical_dedup(&mut self, plan: &LogicalDedup) -> Self::Result { ... }
    fn visit_logical_intersect(
        &mut self,
        plan: &LogicalIntersect,
    ) -> Self::Result { ... }
    fn visit_logical_except(&mut self, plan: &LogicalExcept) -> Self::Result { ... }
    fn visit_logical_max_one_row(
        &mut self,
        plan: &LogicalMaxOneRow,
    ) -> Self::Result { ... }
    fn visit_logical_kafka_scan(
        &mut self,
        plan: &LogicalKafkaScan,
    ) -> Self::Result { ... }
    fn visit_logical_iceberg_scan(
        &mut self,
        plan: &LogicalIcebergScan,
    ) -> Self::Result { ... }
    fn visit_logical_recursive_union(
        &mut self,
        plan: &LogicalRecursiveUnion,
    ) -> Self::Result { ... }
    fn visit_logical_cte_ref(&mut self, plan: &LogicalCteRef) -> Self::Result { ... }
    fn visit_logical_change_log(
        &mut self,
        plan: &LogicalChangeLog,
    ) -> Self::Result { ... }
    fn visit_logical_file_scan(
        &mut self,
        plan: &LogicalFileScan,
    ) -> Self::Result { ... }
    fn visit_logical_postgres_query(
        &mut self,
        plan: &LogicalPostgresQuery,
    ) -> Self::Result { ... }
    fn visit_logical_my_sql_query(
        &mut self,
        plan: &LogicalMySqlQuery,
    ) -> Self::Result { ... }
    fn visit_batch_simple_agg(&mut self, plan: &BatchSimpleAgg) -> Self::Result { ... }
    fn visit_batch_hash_agg(&mut self, plan: &BatchHashAgg) -> Self::Result { ... }
    fn visit_batch_sort_agg(&mut self, plan: &BatchSortAgg) -> Self::Result { ... }
    fn visit_batch_project(&mut self, plan: &BatchProject) -> Self::Result { ... }
    fn visit_batch_filter(&mut self, plan: &BatchFilter) -> Self::Result { ... }
    fn visit_batch_insert(&mut self, plan: &BatchInsert) -> Self::Result { ... }
    fn visit_batch_delete(&mut self, plan: &BatchDelete) -> Self::Result { ... }
    fn visit_batch_update(&mut self, plan: &BatchUpdate) -> Self::Result { ... }
    fn visit_batch_seq_scan(&mut self, plan: &BatchSeqScan) -> Self::Result { ... }
    fn visit_batch_sys_seq_scan(
        &mut self,
        plan: &BatchSysSeqScan,
    ) -> Self::Result { ... }
    fn visit_batch_log_seq_scan(
        &mut self,
        plan: &BatchLogSeqScan,
    ) -> Self::Result { ... }
    fn visit_batch_hash_join(&mut self, plan: &BatchHashJoin) -> Self::Result { ... }
    fn visit_batch_nested_loop_join(
        &mut self,
        plan: &BatchNestedLoopJoin,
    ) -> Self::Result { ... }
    fn visit_batch_values(&mut self, plan: &BatchValues) -> Self::Result { ... }
    fn visit_batch_sort(&mut self, plan: &BatchSort) -> Self::Result { ... }
    fn visit_batch_exchange(&mut self, plan: &BatchExchange) -> Self::Result { ... }
    fn visit_batch_limit(&mut self, plan: &BatchLimit) -> Self::Result { ... }
    fn visit_batch_top_n(&mut self, plan: &BatchTopN) -> Self::Result { ... }
    fn visit_batch_hop_window(&mut self, plan: &BatchHopWindow) -> Self::Result { ... }
    fn visit_batch_table_function(
        &mut self,
        plan: &BatchTableFunction,
    ) -> Self::Result { ... }
    fn visit_batch_expand(&mut self, plan: &BatchExpand) -> Self::Result { ... }
    fn visit_batch_lookup_join(
        &mut self,
        plan: &BatchLookupJoin,
    ) -> Self::Result { ... }
    fn visit_batch_project_set(
        &mut self,
        plan: &BatchProjectSet,
    ) -> Self::Result { ... }
    fn visit_batch_union(&mut self, plan: &BatchUnion) -> Self::Result { ... }
    fn visit_batch_group_top_n(&mut self, plan: &BatchGroupTopN) -> Self::Result { ... }
    fn visit_batch_source(&mut self, plan: &BatchSource) -> Self::Result { ... }
    fn visit_batch_over_window(
        &mut self,
        plan: &BatchOverWindow,
    ) -> Self::Result { ... }
    fn visit_batch_max_one_row(&mut self, plan: &BatchMaxOneRow) -> Self::Result { ... }
    fn visit_batch_kafka_scan(&mut self, plan: &BatchKafkaScan) -> Self::Result { ... }
    fn visit_batch_iceberg_scan(
        &mut self,
        plan: &BatchIcebergScan,
    ) -> Self::Result { ... }
    fn visit_batch_file_scan(&mut self, plan: &BatchFileScan) -> Self::Result { ... }
    fn visit_batch_postgres_query(
        &mut self,
        plan: &BatchPostgresQuery,
    ) -> Self::Result { ... }
    fn visit_batch_my_sql_query(
        &mut self,
        plan: &BatchMySqlQuery,
    ) -> 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 { ... }
}

The visitor for plan nodes. visit all inputs and return the ret value of the left most input, and leaf node returns R::default()

Required Associated Types

type Result: Default

type DefaultBehavior: DefaultBehavior<Self::Result>

Required Methods

fn default_behavior() -> Self::DefaultBehavior

The behavior for the default implementations of visit_xxx.

Provided Methods

fn visit(&mut self, plan: PlanRef) -> Self::Result

fn visit_logical_agg(&mut self, plan: &LogicalAgg) -> Self::Result

Visit LogicalAgg , the function should visit the inputs.

fn visit_logical_apply(&mut self, plan: &LogicalApply) -> Self::Result

Visit LogicalApply , the function should visit the inputs.

fn visit_logical_filter(&mut self, plan: &LogicalFilter) -> Self::Result

Visit LogicalFilter , the function should visit the inputs.

fn visit_logical_project(&mut self, plan: &LogicalProject) -> Self::Result

Visit LogicalProject , the function should visit the inputs.

fn visit_logical_scan(&mut self, plan: &LogicalScan) -> Self::Result

Visit LogicalScan , the function should visit the inputs.

fn visit_logical_cdc_scan(&mut self, plan: &LogicalCdcScan) -> Self::Result

Visit LogicalCdcScan , the function should visit the inputs.

fn visit_logical_sys_scan(&mut self, plan: &LogicalSysScan) -> Self::Result

Visit LogicalSysScan , the function should visit the inputs.

fn visit_logical_source(&mut self, plan: &LogicalSource) -> Self::Result

Visit LogicalSource , the function should visit the inputs.

fn visit_logical_insert(&mut self, plan: &LogicalInsert) -> Self::Result

Visit LogicalInsert , the function should visit the inputs.

fn visit_logical_delete(&mut self, plan: &LogicalDelete) -> Self::Result

Visit LogicalDelete , the function should visit the inputs.

fn visit_logical_update(&mut self, plan: &LogicalUpdate) -> Self::Result

Visit LogicalUpdate , the function should visit the inputs.

fn visit_logical_join(&mut self, plan: &LogicalJoin) -> Self::Result

Visit LogicalJoin , the function should visit the inputs.

fn visit_logical_values(&mut self, plan: &LogicalValues) -> Self::Result

Visit LogicalValues , the function should visit the inputs.

fn visit_logical_limit(&mut self, plan: &LogicalLimit) -> Self::Result

Visit LogicalLimit , the function should visit the inputs.

fn visit_logical_top_n(&mut self, plan: &LogicalTopN) -> Self::Result

Visit LogicalTopN , the function should visit the inputs.

fn visit_logical_hop_window(&mut self, plan: &LogicalHopWindow) -> Self::Result

Visit LogicalHopWindow , the function should visit the inputs.

fn visit_logical_table_function( &mut self, plan: &LogicalTableFunction, ) -> Self::Result

Visit LogicalTableFunction , the function should visit the inputs.

fn visit_logical_multi_join(&mut self, plan: &LogicalMultiJoin) -> Self::Result

Visit LogicalMultiJoin , the function should visit the inputs.

fn visit_logical_expand(&mut self, plan: &LogicalExpand) -> Self::Result

Visit LogicalExpand , the function should visit the inputs.

fn visit_logical_project_set( &mut self, plan: &LogicalProjectSet, ) -> Self::Result

Visit LogicalProjectSet , the function should visit the inputs.

fn visit_logical_union(&mut self, plan: &LogicalUnion) -> Self::Result

Visit LogicalUnion , the function should visit the inputs.

fn visit_logical_over_window( &mut self, plan: &LogicalOverWindow, ) -> Self::Result

Visit LogicalOverWindow , the function should visit the inputs.

fn visit_logical_share(&mut self, plan: &LogicalShare) -> Self::Result

Visit LogicalShare , the function should visit the inputs.

fn visit_logical_now(&mut self, plan: &LogicalNow) -> Self::Result

Visit LogicalNow , the function should visit the inputs.

fn visit_logical_dedup(&mut self, plan: &LogicalDedup) -> Self::Result

Visit LogicalDedup , the function should visit the inputs.

fn visit_logical_intersect(&mut self, plan: &LogicalIntersect) -> Self::Result

Visit LogicalIntersect , the function should visit the inputs.

fn visit_logical_except(&mut self, plan: &LogicalExcept) -> Self::Result

Visit LogicalExcept , the function should visit the inputs.

fn visit_logical_max_one_row(&mut self, plan: &LogicalMaxOneRow) -> Self::Result

Visit LogicalMaxOneRow , the function should visit the inputs.

fn visit_logical_kafka_scan(&mut self, plan: &LogicalKafkaScan) -> Self::Result

Visit LogicalKafkaScan , the function should visit the inputs.

fn visit_logical_iceberg_scan( &mut self, plan: &LogicalIcebergScan, ) -> Self::Result

Visit LogicalIcebergScan , the function should visit the inputs.

fn visit_logical_recursive_union( &mut self, plan: &LogicalRecursiveUnion, ) -> Self::Result

Visit LogicalRecursiveUnion , the function should visit the inputs.

fn visit_logical_cte_ref(&mut self, plan: &LogicalCteRef) -> Self::Result

Visit LogicalCteRef , the function should visit the inputs.

fn visit_logical_change_log(&mut self, plan: &LogicalChangeLog) -> Self::Result

Visit LogicalChangeLog , the function should visit the inputs.

fn visit_logical_file_scan(&mut self, plan: &LogicalFileScan) -> Self::Result

Visit LogicalFileScan , the function should visit the inputs.

fn visit_logical_postgres_query( &mut self, plan: &LogicalPostgresQuery, ) -> Self::Result

Visit LogicalPostgresQuery , the function should visit the inputs.

fn visit_logical_my_sql_query( &mut self, plan: &LogicalMySqlQuery, ) -> Self::Result

Visit LogicalMySqlQuery , the function should visit the inputs.

fn visit_batch_simple_agg(&mut self, plan: &BatchSimpleAgg) -> Self::Result

Visit BatchSimpleAgg , the function should visit the inputs.

fn visit_batch_hash_agg(&mut self, plan: &BatchHashAgg) -> Self::Result

Visit BatchHashAgg , the function should visit the inputs.

fn visit_batch_sort_agg(&mut self, plan: &BatchSortAgg) -> Self::Result

Visit BatchSortAgg , the function should visit the inputs.

fn visit_batch_project(&mut self, plan: &BatchProject) -> Self::Result

Visit BatchProject , the function should visit the inputs.

fn visit_batch_filter(&mut self, plan: &BatchFilter) -> Self::Result

Visit BatchFilter , the function should visit the inputs.

fn visit_batch_insert(&mut self, plan: &BatchInsert) -> Self::Result

Visit BatchInsert , the function should visit the inputs.

fn visit_batch_delete(&mut self, plan: &BatchDelete) -> Self::Result

Visit BatchDelete , the function should visit the inputs.

fn visit_batch_update(&mut self, plan: &BatchUpdate) -> Self::Result

Visit BatchUpdate , the function should visit the inputs.

fn visit_batch_seq_scan(&mut self, plan: &BatchSeqScan) -> Self::Result

Visit BatchSeqScan , the function should visit the inputs.

fn visit_batch_sys_seq_scan(&mut self, plan: &BatchSysSeqScan) -> Self::Result

Visit BatchSysSeqScan , the function should visit the inputs.

fn visit_batch_log_seq_scan(&mut self, plan: &BatchLogSeqScan) -> Self::Result

Visit BatchLogSeqScan , the function should visit the inputs.

fn visit_batch_hash_join(&mut self, plan: &BatchHashJoin) -> Self::Result

Visit BatchHashJoin , the function should visit the inputs.

fn visit_batch_nested_loop_join( &mut self, plan: &BatchNestedLoopJoin, ) -> Self::Result

Visit BatchNestedLoopJoin , the function should visit the inputs.

fn visit_batch_values(&mut self, plan: &BatchValues) -> Self::Result

Visit BatchValues , the function should visit the inputs.

fn visit_batch_sort(&mut self, plan: &BatchSort) -> Self::Result

Visit BatchSort , the function should visit the inputs.

fn visit_batch_exchange(&mut self, plan: &BatchExchange) -> Self::Result

Visit BatchExchange , the function should visit the inputs.

fn visit_batch_limit(&mut self, plan: &BatchLimit) -> Self::Result

Visit BatchLimit , the function should visit the inputs.

fn visit_batch_top_n(&mut self, plan: &BatchTopN) -> Self::Result

Visit BatchTopN , the function should visit the inputs.

fn visit_batch_hop_window(&mut self, plan: &BatchHopWindow) -> Self::Result

Visit BatchHopWindow , the function should visit the inputs.

fn visit_batch_table_function( &mut self, plan: &BatchTableFunction, ) -> Self::Result

Visit BatchTableFunction , the function should visit the inputs.

fn visit_batch_expand(&mut self, plan: &BatchExpand) -> Self::Result

Visit BatchExpand , the function should visit the inputs.

fn visit_batch_lookup_join(&mut self, plan: &BatchLookupJoin) -> Self::Result

Visit BatchLookupJoin , the function should visit the inputs.

fn visit_batch_project_set(&mut self, plan: &BatchProjectSet) -> Self::Result

Visit BatchProjectSet , the function should visit the inputs.

fn visit_batch_union(&mut self, plan: &BatchUnion) -> Self::Result

Visit BatchUnion , the function should visit the inputs.

fn visit_batch_group_top_n(&mut self, plan: &BatchGroupTopN) -> Self::Result

Visit BatchGroupTopN , the function should visit the inputs.

fn visit_batch_source(&mut self, plan: &BatchSource) -> Self::Result

Visit BatchSource , the function should visit the inputs.

fn visit_batch_over_window(&mut self, plan: &BatchOverWindow) -> Self::Result

Visit BatchOverWindow , the function should visit the inputs.

fn visit_batch_max_one_row(&mut self, plan: &BatchMaxOneRow) -> Self::Result

Visit BatchMaxOneRow , the function should visit the inputs.

fn visit_batch_kafka_scan(&mut self, plan: &BatchKafkaScan) -> Self::Result

Visit BatchKafkaScan , the function should visit the inputs.

fn visit_batch_iceberg_scan(&mut self, plan: &BatchIcebergScan) -> Self::Result

Visit BatchIcebergScan , the function should visit the inputs.

fn visit_batch_file_scan(&mut self, plan: &BatchFileScan) -> Self::Result

Visit BatchFileScan , the function should visit the inputs.

fn visit_batch_postgres_query( &mut self, plan: &BatchPostgresQuery, ) -> Self::Result

Visit BatchPostgresQuery , the function should visit the inputs.

fn visit_batch_my_sql_query(&mut self, plan: &BatchMySqlQuery) -> Self::Result

Visit BatchMySqlQuery , the function should visit the inputs.

fn visit_stream_project(&mut self, plan: &StreamProject) -> Self::Result

Visit StreamProject , the function should visit the inputs.

fn visit_stream_filter(&mut self, plan: &StreamFilter) -> Self::Result

Visit StreamFilter , the function should visit the inputs.

fn visit_stream_table_scan(&mut self, plan: &StreamTableScan) -> Self::Result

Visit StreamTableScan , the function should visit the inputs.

fn visit_stream_cdc_table_scan( &mut self, plan: &StreamCdcTableScan, ) -> Self::Result

Visit StreamCdcTableScan , the function should visit the inputs.

fn visit_stream_sink(&mut self, plan: &StreamSink) -> Self::Result

Visit StreamSink , the function should visit the inputs.

fn visit_stream_source(&mut self, plan: &StreamSource) -> Self::Result

Visit StreamSource , the function should visit the inputs.

fn visit_stream_source_scan(&mut self, plan: &StreamSourceScan) -> Self::Result

Visit StreamSourceScan , the function should visit the inputs.

fn visit_stream_hash_join(&mut self, plan: &StreamHashJoin) -> Self::Result

Visit StreamHashJoin , the function should visit the inputs.

fn visit_stream_exchange(&mut self, plan: &StreamExchange) -> Self::Result

Visit StreamExchange , the function should visit the inputs.

fn visit_stream_hash_agg(&mut self, plan: &StreamHashAgg) -> Self::Result

Visit StreamHashAgg , the function should visit the inputs.

fn visit_stream_simple_agg(&mut self, plan: &StreamSimpleAgg) -> Self::Result

Visit StreamSimpleAgg , the function should visit the inputs.

fn visit_stream_stateless_simple_agg( &mut self, plan: &StreamStatelessSimpleAgg, ) -> Self::Result

Visit StreamStatelessSimpleAgg , the function should visit the inputs.

fn visit_stream_materialize(&mut self, plan: &StreamMaterialize) -> Self::Result

Visit StreamMaterialize , the function should visit the inputs.

fn visit_stream_top_n(&mut self, plan: &StreamTopN) -> Self::Result

Visit StreamTopN , the function should visit the inputs.

fn visit_stream_hop_window(&mut self, plan: &StreamHopWindow) -> Self::Result

Visit StreamHopWindow , the function should visit the inputs.

fn visit_stream_delta_join(&mut self, plan: &StreamDeltaJoin) -> Self::Result

Visit StreamDeltaJoin , the function should visit the inputs.

fn visit_stream_expand(&mut self, plan: &StreamExpand) -> Self::Result

Visit StreamExpand , the function should visit the inputs.

fn visit_stream_dynamic_filter( &mut self, plan: &StreamDynamicFilter, ) -> Self::Result

Visit StreamDynamicFilter , the function should visit the inputs.

fn visit_stream_project_set(&mut self, plan: &StreamProjectSet) -> Self::Result

Visit StreamProjectSet , the function should visit the inputs.

fn visit_stream_group_top_n(&mut self, plan: &StreamGroupTopN) -> Self::Result

Visit StreamGroupTopN , the function should visit the inputs.

fn visit_stream_union(&mut self, plan: &StreamUnion) -> Self::Result

Visit StreamUnion , the function should visit the inputs.

fn visit_stream_row_id_gen(&mut self, plan: &StreamRowIdGen) -> Self::Result

Visit StreamRowIdGen , the function should visit the inputs.

fn visit_stream_dml(&mut self, plan: &StreamDml) -> Self::Result

Visit StreamDml , the function should visit the inputs.

fn visit_stream_now(&mut self, plan: &StreamNow) -> Self::Result

Visit StreamNow , the function should visit the inputs.

fn visit_stream_share(&mut self, plan: &StreamShare) -> Self::Result

Visit StreamShare , the function should visit the inputs.

fn visit_stream_watermark_filter( &mut self, plan: &StreamWatermarkFilter, ) -> Self::Result

Visit StreamWatermarkFilter , the function should visit the inputs.

fn visit_stream_temporal_join( &mut self, plan: &StreamTemporalJoin, ) -> Self::Result

Visit StreamTemporalJoin , the function should visit the inputs.

fn visit_stream_values(&mut self, plan: &StreamValues) -> Self::Result

Visit StreamValues , the function should visit the inputs.

fn visit_stream_dedup(&mut self, plan: &StreamDedup) -> Self::Result

Visit StreamDedup , the function should visit the inputs.

fn visit_stream_eowc_over_window( &mut self, plan: &StreamEowcOverWindow, ) -> Self::Result

Visit StreamEowcOverWindow , the function should visit the inputs.

fn visit_stream_eowc_sort(&mut self, plan: &StreamEowcSort) -> Self::Result

Visit StreamEowcSort , the function should visit the inputs.

fn visit_stream_over_window(&mut self, plan: &StreamOverWindow) -> Self::Result

Visit StreamOverWindow , the function should visit the inputs.

fn visit_stream_fs_fetch(&mut self, plan: &StreamFsFetch) -> Self::Result

Visit StreamFsFetch , the function should visit the inputs.

fn visit_stream_change_log(&mut self, plan: &StreamChangeLog) -> Self::Result

Visit StreamChangeLog , the function should visit the inputs.

fn visit_stream_global_approx_percentile( &mut self, plan: &StreamGlobalApproxPercentile, ) -> Self::Result

Visit StreamGlobalApproxPercentile , the function should visit the inputs.

fn visit_stream_local_approx_percentile( &mut self, plan: &StreamLocalApproxPercentile, ) -> Self::Result

Visit StreamLocalApproxPercentile , the function should visit the inputs.

fn visit_stream_row_merge(&mut self, plan: &StreamRowMerge) -> Self::Result

Visit StreamRowMerge , the function should visit the inputs.

fn visit_stream_as_of_join(&mut self, plan: &StreamAsOfJoin) -> Self::Result

Visit StreamAsOfJoin , the function should visit the inputs.

fn visit_stream_sync_log_store( &mut self, plan: &StreamSyncLogStore, ) -> Self::Result

Visit StreamSyncLogStore , the function should visit the inputs.

fn visit_stream_materialized_exprs( &mut self, plan: &StreamMaterializedExprs, ) -> Self::Result

Visit StreamMaterializedExprs , the function should visit the inputs.

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.

Implementors

impl PlanVisitor for SourceCounter

type Result = ()

type DefaultBehavior = impl DefaultBehavior<<SourceCounter as PlanVisitor>::Result>

impl PlanVisitor for CheckApplyElimination

type Result = ()

type DefaultBehavior = impl DefaultBehavior<<CheckApplyElimination as PlanVisitor>::Result>

impl PlanVisitor for HasMaxOneRowApply

type Result = bool

type DefaultBehavior = impl DefaultBehavior<<HasMaxOneRowApply as PlanVisitor>::Result>

impl PlanVisitor for CardinalityVisitor

type Result = Cardinality

type DefaultBehavior = impl DefaultBehavior<<CardinalityVisitor as PlanVisitor>::Result>

impl PlanVisitor for DistributedDmlVisitor

type Result = bool

type DefaultBehavior = impl DefaultBehavior<<DistributedDmlVisitor as PlanVisitor>::Result>

impl PlanVisitor for InputRefValidator

type Result = Option<String>

type DefaultBehavior = impl DefaultBehavior<<InputRefValidator as PlanVisitor>::Result>

impl PlanVisitor for StreamKeyChecker

type Result = Option<String>

type DefaultBehavior = impl DefaultBehavior<<StreamKeyChecker as PlanVisitor>::Result>

impl PlanVisitor for PlanCorrelatedIdFinder

type Result = ()

type DefaultBehavior = impl DefaultBehavior<<PlanCorrelatedIdFinder as PlanVisitor>::Result>

impl PlanVisitor for RwTimestampValidator

type Result = bool

type DefaultBehavior = impl DefaultBehavior<<RwTimestampValidator as PlanVisitor>::Result>

impl PlanVisitor for ShareParentCounter

type Result = ()

type DefaultBehavior = impl DefaultBehavior<<ShareParentCounter as PlanVisitor>::Result>

impl PlanVisitor for SideEffectVisitor

type Result = bool

type DefaultBehavior = impl DefaultBehavior<<SideEffectVisitor as PlanVisitor>::Result>

impl PlanVisitor for TemporalJoinValidator

type Result = bool

type DefaultBehavior = impl DefaultBehavior<<TemporalJoinValidator as PlanVisitor>::Result>

impl PlanVisitor for ExecutionModeDecider

type Result = bool

type DefaultBehavior = impl DefaultBehavior<<ExecutionModeDecider as PlanVisitor>::Result>

impl PlanVisitor for ReadStorageTableVisitor

type Result = ()

type DefaultBehavior = impl DefaultBehavior<<ReadStorageTableVisitor as PlanVisitor>::Result>

impl PlanVisitor for RelationCollectorVisitor

type Result = ()

type DefaultBehavior = impl DefaultBehavior<<RelationCollectorVisitor as PlanVisitor>::Result>

impl PlanVisitor for SysTableVisitor

type Result = bool

type DefaultBehavior = impl DefaultBehavior<<SysTableVisitor as PlanVisitor>::Result>