risingwave_frontend::optimizer::plan_node

Module stream_sink

Structs§

IcebergPartitionInfo
StreamSink: StreamSink represents a table/connector sink at the very end of the graph.

Enums§

PartitionComputeInfo: Why we need PartitionComputeInfo?

Constants§

CREATE_TABLE_IF_NOT_EXISTS 🔒
DOWNSTREAM_PK_KEY 🔒

Functions§

find_column_idx_by_name 🔒