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.

Structs

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

Type Aliases

PbAzblobFileScanNode

Alias for AzblobFileScanNode.

PbDeleteNode

Alias for DeleteNode.

PbDistributedLookupJoinNode

Alias for DistributedLookupJoinNode.

PbExchangeInfo

Alias for ExchangeInfo.

PbExchangeNode

Alias for ExchangeNode.

PbExchangeSource

Alias for ExchangeSource.

PbExpandNode

Alias for ExpandNode.

PbFileScanNode

Alias for FileScanNode.

PbFilterNode

Alias for FilterNode.

PbGcsFileScanNode

Alias for GcsFileScanNode.

PbGroupTopNNode

Alias for GroupTopNNode.

PbHashAggNode

Alias for HashAggNode.

PbHashJoinNode

Alias for HashJoinNode.

PbHopWindowNode

Alias for HopWindowNode.

PbIcebergScanNode

Alias for IcebergScanNode.

PbInsertNode

Alias for InsertNode.

PbLimitNode

Alias for LimitNode.

PbLocalExecutePlan

Alias for LocalExecutePlan.

PbLocalLookupJoinNode

Alias for LocalLookupJoinNode.

PbLogRowSeqScanNode

Alias for LogRowSeqScanNode.

PbMaxOneRowNode

Alias for MaxOneRowNode.

PbMergeSortExchangeNode

Alias for MergeSortExchangeNode.

PbMySqlQueryNode

Alias for MySqlQueryNode.

PbNestedLoopJoinNode

Alias for NestedLoopJoinNode.

PbPlanFragment

Alias for PlanFragment.

PbPlanNode

Alias for PlanNode.

PbPostgresQueryNode

Alias for PostgresQueryNode.

PbProjectNode

Alias for ProjectNode.

PbProjectSetNode

Alias for ProjectSetNode.

PbRowSeqScanNode

Alias for RowSeqScanNode.

PbScanRange

Alias for ScanRange.

PbSortAggNode

Alias for SortAggNode.

PbSortMergeJoinNode

Alias for SortMergeJoinNode.

PbSortNode

Alias for SortNode.

PbSortOverWindowNode

Alias for SortOverWindowNode.

PbSourceNode

Alias for SourceNode.

PbSysRowSeqScanNode

Alias for SysRowSeqScanNode.

PbTableFunctionNode

Alias for TableFunctionNode.

PbTaskId

Alias for TaskId.

PbTaskOutputId

Alias for TaskOutputId.

PbTopNNode

Alias for TopNNode.

PbUnionNode

Alias for UnionNode.

PbUpdateNode

Alias for UpdateNode.

PbValuesNode

Alias for ValuesNode.