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 add_logstore_rule::*;

pub use batch::batch_iceberg_count_star::*;

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

add_logstore_rule 🔒

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 🔒