Module sink 

Structs

JdbcUrl 🔒

SinkExecutorBuilder

Functions

build_sink_param 🔒

Build SinkParam from a PbSinkDesc, along with the full ColumnCatalog list for downstream use. connector is the resolved connector name (e.g. ICEBERG_SINK), used for legacy type = '...' format/encode fallback and connector-specific backward-compatibility conversions.

parse_jdbc_url 🔒

resolve_pk_info 🔒

validate_payload_schema 🔒