pub(super) fn build_sink_param(
sink_desc: &PbSinkDesc,
properties_with_secret: BTreeMap<String, String>,
connector: &str,
) -> Result<(SinkParam, Vec<ColumnCatalog>), StreamExecutorError>Expand description
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.
The caller is responsible for preparing properties_with_secret (i.e. the result of
LocalSecretManager::fill_secrets plus any connector-specific rewrites such as the
JDBC-to-native-postgres switch).