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 🔒

is_iceberg_with_pk_index_sink

promote_iceberg_pk_index_stream_key 🔒

For Iceberg pk-index sinks, promote the downstream_pk and sink columns that use the full upstream stream key as the iceberg primary key.

target_table_requires_row_level_conflict_handling 🔒