Module stream_sink

risingwave_frontend::optimizer::plan_node

Module stream_sink 

Source

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 🔒