Module generic

This module contains the generic plan nodes that are shared by all the plan nodes. They are meant to reuse the common fields between logical, batch and stream nodes.

Re-exports

• pub use dynamic_filter::*;

Modules

• agg 🔒
• cdc_scan 🔒
• changelog 🔒
• cte_ref 🔒
• dedup 🔒
• delete 🔒
• dynamic_filter
• except 🔒
• expand 🔒
• file_scan 🔒
• filter 🔒
• hop_window 🔒
• insert 🔒
• intersect 🔒
• join 🔒
• limit 🔒
• log_scan 🔒
• max_one_row 🔒
• mysql_query 🔒
• now 🔒
• over_window 🔒
• postgres_query 🔒
• project 🔒
• project_set 🔒
• recursive_union 🔒
• share 🔒
• source 🔒
• sys_scan 🔒
• table_scan 🔒
• top_n 🔒
• union 🔒
• update 🔒

Macros

• impl_distill_unit_from_fields 🔒

Structs

• Agg
  Agg groups input data by their group key and computes aggregation functions.
• AliasedExpr
  Auxiliary struct for displaying expr AS alias
• CdcScan
  CdcScan reads rows of a table from an external upstream database
• CdcScanOptions
• ChangeLog
• CteRef
• Dedup
• Delete
• Except
  Except returns the rows of its first input except any matching rows from its other inputs.
• Expand
  Expand expand one row multiple times according to column_subsets and also keep original columns of input. It can be used to implement distinct aggregation and group set.
• FileScan
• Filter
• HopWindow
  HopWindow implements Hop Table Function.
• Insert
• Intersect
  Intersect returns the intersect of the rows of its inputs. If all is false, it needs to eliminate duplicates.
• Join
  Join combines two relations according to some condition.
• Limit
• LogScan
• MaterializedInputState
• MaxOneRow
• MySqlQuery
• Now
• OverWindow
• PlanAggCall
  Rewritten version of crate::expr::AggCall which uses InputRef instead of ExprImpl. Refer to crate::optimizer::plan_node::logical_agg::LogicalAggBuilder::try_rewrite_agg_call for more details.
• PlanAggCallDisplay
• PlanWindowFunction
  Rewritten version of crate::expr::WindowFunction which uses InputRef instead of ExprImpl.
• PostgresQuery
• Project
  Project computes a set of expressions from its input relation.
• ProjectBuilder
  Construct a Project and dedup expressions. expressions
• ProjectSet
  ProjectSet projects one row multiple times according to select_list.
• RecursiveUnion
  RecursiveUnion returns the union of the rows of its inputs. note: if all is false, it needs to eliminate duplicates.
• Share
• Source
  Source returns contents of a table or other equivalent object
• SysScan
  SysScan returns contents of a table or other equivalent object
• TableScan
  TableScan returns contents of a RisingWave Table.
• TopN
  TopN sorts the input data and fetches up to limit rows from offset
• Union
  Union returns the union of the rows of its inputs. If all is false, it needs to eliminate duplicates.
• Update

Enums

• AggCallState
• FileFormat
• Mode
• SourceNodeKind
  In which scnario the source node is created
• StorageType
• TopNLimit
  Limit is used to specify the number of records to return.

Constants

• CHANGELOG_OP
• _CHANGELOG_ROW_ID

Traits

• DistillUnit
• GenericPlanNode
• GenericPlanRef
• PhysicalPlanRef

Functions

• can_push_left_from_filter
• can_push_left_from_on
• can_push_on_from_filter
• can_push_right_from_filter
• can_push_right_from_on
• push_down_into_join
  Try to split and pushdown predicate into a into a join condition and into the inputs of the join. Returns the pushed predicates. The pushed part will be removed from the original predicate.
• push_down_join_condition
  Try to pushes parts of the join condition to its inputs. Returns the pushed predicates. The pushed part will be removed from the original join predicate.