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 🔒

locality_provider 🔒

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 🔒

vector_index_lookup_join 🔒

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

AzblobFileScan

CdcScan

CdcScan reads rows of a table from an external upstream database

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

GcsFileScan

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

LocalityProvider

LocalityProvider provides locality for operators during backfilling. It buffers input data into a state table using locality columns as primary key prefix.

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

VectorIndexLookupJoin

Enums

AggCallState

FileFormat

FileScanBackend

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

build_cdc_scan_options_with_options

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

ensure_sorted_required_cols

Given the index of required cols, return a vec of permutation index, so that after we sort the required_cols, and re-apply with a projection with the permutation index, we can restore the original required_cols.

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.