Struct ExecutionModeDecider

pub struct ExecutionModeDecider {}

Implementations

impl ExecutionModeDecider

pub fn run_in_local_mode(plan: PlanRef) -> bool

If the plan should run in local mode, return true; otherwise, return false.

Trait Implementations

impl Clone for ExecutionModeDecider

fn clone(&self) -> ExecutionModeDecider

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ExecutionModeDecider

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ExecutionModeDecider

fn default() -> ExecutionModeDecider

Returns the “default value” for a type.

impl PlanVisitor for ExecutionModeDecider

fn visit_batch_seq_scan(&mut self, batch_seq_scan: &BatchSeqScan) -> bool

Point select, index lookup and two side bound range scan. select * from t where id = 1 select * from t where k = 1 select * from t where id between 1 and 5

fn visit_batch_values(&mut self, _batch_values: &BatchValues) -> bool

Simple value select. select 1

fn visit_batch_limit(&mut self, batch_limit: &BatchLimit) -> bool

Limit scan. select * from t limit 1 select * from t order by k limit 1

type Result = bool

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

fn default_behavior() -> Self::DefaultBehavior

The behavior for the default implementations of visit_xxx.

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_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_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_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.