Module batch_plan

Modules

• 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.
• 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

• 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
• 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

• 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.
• 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.