Module merge_
eq_
nodes
risingwave_
frontend
2.4.0-alpha
Module merge_
eq_
nodes
Module Items
Structs
Traits
In risingwave_
frontend::
optimizer::
plan_
node
Modules
batch
batch_delete
batch_exchange
batch_expand
batch_file_scan
batch_filter
batch_group_topn
batch_hash_agg
batch_hash_join
batch_hop_window
batch_iceberg_scan
batch_insert
batch_kafka_scan
batch_limit
batch_log_seq_scan
batch_lookup_join
batch_max_one_row
batch_mysql_query
batch_nested_loop_join
batch_over_window
batch_postgres_query
batch_project
batch_project_set
batch_seq_scan
batch_simple_agg
batch_sort
batch_sort_agg
batch_source
batch_sys_seq_scan
batch_table_function
batch_topn
batch_union
batch_update
batch_values
col_pruning
convert
derive
eq_join_predicate
expr_rewritable
expr_visitable
generic
logical_agg
logical_apply
logical_cdc_scan
logical_changelog
logical_cte_ref
logical_dedup
logical_delete
logical_except
logical_expand
logical_file_scan
logical_filter
logical_hop_window
logical_iceberg_scan
logical_insert
logical_intersect
logical_join
logical_kafka_scan
logical_limit
logical_max_one_row
logical_multi_join
logical_mysql_query
logical_now
logical_over_window
logical_postgres_query
logical_project
logical_project_set
logical_recursive_union
logical_scan
logical_share
logical_source
logical_sys_scan
logical_table_function
logical_topn
logical_union
logical_update
logical_values
merge_eq_nodes
plan_base
plan_node_meta
plan_tree_node
predicate_pushdown
stream
stream_asof_join
stream_cdc_table_scan
stream_changelog
stream_dedup
stream_delta_join
stream_dml
stream_dynamic_filter
stream_eowc_over_window
stream_exchange
stream_expand
stream_filter
stream_fs_fetch
stream_global_approx_percentile
stream_group_topn
stream_hash_agg
stream_hash_join
stream_hop_window
stream_join_common
stream_local_approx_percentile
stream_materialize
stream_materialized_exprs
stream_now
stream_over_window
stream_project
stream_project_set
stream_row_id_gen
stream_row_merge
stream_share
stream_simple_agg
stream_sink
stream_sort
stream_source
stream_source_scan
stream_stateless_simple_agg
stream_sync_log_store
stream_table_scan
stream_temporal_join
stream_topn
stream_union
stream_values
stream_watermark_filter
to_prost
utils
Macros
impl_down_cast_fn
impl_plan_node
impl_plan_node_meta
Structs
Batch
BatchDelete
BatchExchange
BatchExpand
BatchExtra
BatchFileScan
BatchFilter
BatchGroupTopN
BatchHashAgg
BatchHashJoin
BatchHopWindow
BatchIcebergScan
BatchInsert
BatchKafkaScan
BatchLimit
BatchLogSeqScan
BatchLookupJoin
BatchMaxOneRow
BatchMySqlQuery
BatchNestedLoopJoin
BatchOverWindow
BatchPostgresQuery
BatchProject
BatchProjectSet
BatchSeqScan
BatchSimpleAgg
BatchSort
BatchSortAgg
BatchSource
BatchSysSeqScan
BatchTableFunction
BatchTopN
BatchUnion
BatchUpdate
BatchValues
ColumnPruningContext
EqJoinPredicate
EqJoinPredicateDisplay
IcebergPartitionInfo
Logical
LogicalAgg
LogicalApply
LogicalCdcScan
LogicalChangeLog
LogicalCteRef
LogicalDedup
LogicalDelete
LogicalExcept
LogicalExpand
LogicalFileScan
LogicalFilter
LogicalHopWindow
LogicalIcebergScan
LogicalInsert
LogicalIntersect
LogicalJoin
LogicalKafkaScan
LogicalLimit
LogicalMaxOneRow
LogicalMultiJoin
LogicalMultiJoinBuilder
LogicalMySqlQuery
LogicalNow
LogicalOverWindow
LogicalPostgresQuery
LogicalProject
LogicalProjectSet
LogicalRecursiveUnion
LogicalScan
LogicalShare
LogicalSource
LogicalSysScan
LogicalTableFunction
LogicalTopN
LogicalUnion
LogicalUpdate
LogicalValues
NoExtra
PlanBase
PlanNodeId
PlanRef
PredicatePushdownContext
RewriteStreamContext
Stream
StreamAsOfJoin
StreamCdcTableScan
StreamChangeLog
StreamDedup
StreamDeltaJoin
StreamDml
StreamDynamicFilter
StreamEowcOverWindow
StreamEowcSort
StreamExchange
StreamExpand
StreamExtra
StreamFilter
StreamFsFetch
StreamGlobalApproxPercentile
StreamGroupTopN
StreamHashAgg
StreamHashJoin
StreamHopWindow
StreamLocalApproxPercentile
StreamMaterialize
StreamMaterializedExprs
StreamNow
StreamOverWindow
StreamProject
StreamProjectSet
StreamRowIdGen
StreamRowMerge
StreamShare
StreamSimpleAgg
StreamSink
StreamSource
StreamSourceScan
StreamStatelessSimpleAgg
StreamSyncLogStore
StreamTableScan
StreamTemporalJoin
StreamTopN
StreamUnion
StreamValues
StreamWatermarkFilter
ToStreamContext
Enums
Convention
PartitionComputeInfo
PlanBaseRef
PlanNodeType
Constants
PLAN_DEPTH_THRESHOLD
PLAN_TOO_DEEP_NOTICE
Traits
ColPrunable
ConventionMarker
EndoPlan
Explain
ExprRewritable
PlanNode
PlanNodeMeta
PlanTreeNode
PlanTreeNodeBinary
PlanTreeNodeLeaf
PlanTreeNodeUnary
PredicatePushdown
RewriteExprsRecursive
Semantics
StreamNode
ToBatch
ToBatchPb
ToDistributedBatch
ToLocalBatch
ToPb
ToStream
TryToBatchPb
TryToStreamPb
VisitExprsRecursive
VisitPlan
Functions
gen_filter_and_pushdown
pretty_config
reorganize_elements_id
stream_enforce_eowc_requirement
risingwave_frontend
::
optimizer
::
plan_node
Module
merge_eq_nodes
Copy item path
Settings
Help
Summary
Source
Structs
§
Counter
🔒
Merger
🔒
Pruner
🔒
Traits
§
Semantics