Module rule

Define all Rule

Re-exports

• pub use logical_filter_expression_simplify_rule::*;
• pub use over_window_merge_rule::*;
• pub use project_join_merge_rule::*;
• pub use project_eliminate_rule::*;
• pub use project_merge_rule::*;
• pub use pull_up_correlated_predicate_rule::*;
• pub use index_delta_join_rule::*;
• pub use left_deep_tree_join_ordering_rule::*;
• pub use apply_agg_transpose_rule::*;
• pub use apply_filter_transpose_rule::*;
• pub use apply_project_transpose_rule::*;
• pub use apply_eliminate_rule::*;
• pub use translate_apply_rule::*;
• pub use merge_multijoin_rule::*;
• pub use max_one_row_eliminate_rule::*;
• pub use apply_join_transpose_rule::*;
• pub use apply_to_join_rule::*;
• pub use distinct_agg_rule::*;
• pub use index_selection_rule::*;
• pub use push_calculation_of_join_rule::*;
• pub use over_window_to_agg_and_join_rule::*;
• pub use over_window_split_rule::*;
• pub use join_commute_rule::*;
• pub use over_window_to_topn_rule::*;
• pub use union_to_distinct_rule::*;
• pub use agg_project_merge_rule::*;
• pub use union_merge_rule::*;
• pub use dag_to_tree_rule::*;
• pub use apply_share_eliminate_rule::*;
• pub use top_n_on_index_rule::*;
• pub use stream::bushy_tree_join_ordering_rule::*;
• pub use stream::filter_with_now_to_join_rule::*;
• pub use stream::generate_series_with_now_rule::*;
• pub use stream::split_now_and_rule::*;
• pub use stream::split_now_or_rule::*;
• pub use stream::stream_project_merge_rule::*;
• pub use trivial_project_to_values_rule::*;
• pub use union_input_values_merge_rule::*;
• pub use rewrite_like_expr_rule::*;
• pub use min_max_on_index_rule::*;
• pub use always_false_filter_rule::*;
• pub use join_project_transpose_rule::*;
• pub use limit_push_down_rule::*;
• pub use pull_up_hop_rule::*;
• pub use intersect_to_semi_join_rule::*;
• pub use except_to_anti_join_rule::*;
• pub use intersect_merge_rule::*;
• pub use except_merge_rule::*;
• pub use apply_union_transpose_rule::*;
• pub use apply_dedup_transpose_rule::*;
• pub use project_join_separate_rule::*;
• pub use grouping_sets_to_expand_rule::*;
• pub use apply_project_set_transpose_rule::*;
• pub use cross_join_eliminate_rule::*;
• pub use table_function_to_project_set_rule::*;
• pub use apply_topn_transpose_rule::*;
• pub use apply_limit_transpose_rule::*;
• pub use batch::batch_project_merge_rule::*;
• pub use common_sub_expr_extract_rule::*;
• pub use apply_over_window_transpose_rule::*;
• pub use apply_expand_transpose_rule::*;
• pub use expand_to_project_rule::*;
• pub use agg_group_by_simplify_rule::*;
• pub use apply_hop_window_transpose_rule::*;
• pub use agg_call_merge_rule::*;
• pub use batch::batch_iceberg_predicate_pushdown::*;
• pub use batch::batch_push_limit_to_scan_rule::*;
• pub use pull_up_correlated_predicate_agg_rule::*;
• pub use source_to_iceberg_scan_rule::*;
• pub use source_to_kafka_scan_rule::*;
• pub use table_function_to_file_scan_rule::*;
• pub use table_function_to_mysql_query_rule::*;
• pub use table_function_to_postgres_query_rule::*;
• pub use values_extract_project_rule::*;

Modules

• agg_call_merge_rule 🔒
• agg_group_by_simplify_rule 🔒
• agg_project_merge_rule 🔒
• always_false_filter_rule 🔒
• apply_agg_transpose_rule 🔒
• apply_dedup_transpose_rule 🔒
• apply_eliminate_rule 🔒
• apply_expand_transpose_rule 🔒
• apply_filter_transpose_rule 🔒
• apply_hop_window_transpose_rule 🔒
• apply_join_transpose_rule 🔒
• apply_limit_transpose_rule 🔒
• apply_offset_rewriter 🔒
• apply_over_window_transpose_rule 🔒
• apply_project_set_transpose_rule 🔒
• apply_project_transpose_rule 🔒
• apply_share_eliminate_rule 🔒
• apply_to_join_rule 🔒
• apply_topn_transpose_rule 🔒
• apply_union_transpose_rule 🔒
• batch 🔒
• common_sub_expr_extract_rule 🔒
• cross_join_eliminate_rule 🔒
• dag_to_tree_rule 🔒
• distinct_agg_rule 🔒
• except_merge_rule 🔒
• except_to_anti_join_rule 🔒
• expand_to_project_rule 🔒
• grouping_sets_to_expand_rule 🔒
• index_delta_join_rule 🔒
• index_selection_rule 🔒
  Index selection cost matrix
• intersect_merge_rule 🔒
• intersect_to_semi_join_rule 🔒
• join_commute_rule 🔒
• join_project_transpose_rule 🔒
• left_deep_tree_join_ordering_rule 🔒
• limit_push_down_rule 🔒
• logical_filter_expression_simplify_rule 🔒
• max_one_row_eliminate_rule 🔒
• merge_multijoin_rule 🔒
• min_max_on_index_rule 🔒
• over_window_merge_rule 🔒
• over_window_split_rule 🔒
• over_window_to_agg_and_join_rule 🔒
• over_window_to_topn_rule 🔒
• project_eliminate_rule 🔒
• project_join_merge_rule 🔒
• project_join_separate_rule 🔒
• project_merge_rule 🔒
• pull_up_correlated_predicate_agg_rule 🔒
• pull_up_correlated_predicate_rule 🔒
• pull_up_hop_rule 🔒
• push_calculation_of_join_rule 🔒
• rewrite_like_expr_rule 🔒
• source_to_iceberg_scan_rule 🔒
• source_to_kafka_scan_rule 🔒
• stream 🔒
• table_function_to_file_scan_rule 🔒
• table_function_to_mysql_query_rule 🔒
• table_function_to_postgres_query_rule 🔒
• table_function_to_project_set_rule 🔒
• top_n_on_index_rule 🔒
• translate_apply_rule 🔒
• trivial_project_to_values_rule 🔒
• union_input_values_merge_rule 🔒
• union_merge_rule 🔒
• union_to_distinct_rule 🔒
• values_extract_project_rule 🔒

Macros

• impl_description 🔒

Enums

• ApplyResult
  Result when applying a Rule to a PlanNode.

Traits

• Description
• FallibleRule
  An one-to-one transform for the PlanNode that may return an unrecoverable error that stops further optimization.
• InfallibleRule 🔒
  An one-to-one transform for the PlanNode.

Type Aliases

• BoxedRule 🔒