Module batch_plan

Modules§

azblob_file_scan_node: Nested message and enum types in AzblobFileScanNode.
exchange_info: Nested message and enum types in ExchangeInfo.
exchange_source: Nested message and enum types in ExchangeSource.
expand_node: Nested message and enum types in ExpandNode.
file_scan_node: Nested message and enum types in FileScanNode.
gcs_file_scan_node: Nested message and enum types in GcsFileScanNode.
iceberg_scan_node: Nested message and enum types in IcebergScanNode.
plan_node: Nested message and enum types in PlanNode.
scan_range: Nested message and enum types in ScanRange.
values_node: Nested message and enum types in ValuesNode.

AzblobFileScanNode
DeleteNode
DistributedLookupJoinNode: RFC: A new schedule way for distributed lookup join https://github.com/risingwavelabs/rfcs/pull/6
ExchangeInfo: ExchangeInfo determines how to distribute results to tasks of next stage.
ExchangeNode
ExchangeSource: ExchangeSource describes where to read results from children operators
ExpandNode
FileScanNode
FilterNode
GcsFileScanNode
GroupTopNNode
HashAggNode
HashJoinNode
HopWindowNode
IcebergScanNode
InsertNode
LimitNode
LocalExecutePlan
LocalLookupJoinNode
LogRowSeqScanNode
MaxOneRowNode
MergeSortExchangeNode
MySqlQueryNode: NOTE(kwannoel): This will only be used in batch mode. We can change the definition as needed.
NestedLoopJoinNode
PlanFragment
PlanNode
PostgresQueryNode: NOTE(kwannoel): This will only be used in batch mode. We can change the definition as needed.
ProjectNode
ProjectSetNode
RowSeqScanNode
ScanRange: The range to scan, which specifies a consecutive range of the PK and can represent: (Suppose there are N columns in the PK)
SortAggNode
SortMergeJoinNode
SortNode
SortOverWindowNode
SourceNode
SysRowSeqScanNode
TableFunctionNode
TaskId: Task is a running instance of Stage.
TaskOutputId: Every task will create N buffers (channels) for parent operators to fetch results from, where N is the parallelism of parent stage.
TopNNode
UnionNode
UpdateNode
ValuesNode