risingwave_
frontend
2.2.0-alpha
Module stream_
sink
Module Items
Structs
Enums
Constants
Functions
In risingwave_
frontend::
optimizer::
plan_
node
risingwave_frontend
::
optimizer
::
plan_node
Module
stream_sink
Copy item path
source
Structs
§
Iceberg
Partition
Info
Stream
Sink
StreamSink
represents a table/connector sink at the very end of the graph.
Enums
§
Partition
Compute
Info
Why we need
PartitionComputeInfo
?
Constants
§
DOWNSTREAM_
PK_
KEY
🔒
Functions
§
find_
column_
idx_
by_
name
🔒