Function mz_sql::plan::statement::ddl::source_sink_cluster_config

fn source_sink_cluster_config(
    scx: &StatementContext<'_>,
    ty: &'static str,
    in_cluster: &mut Option<ResolvedClusterName>
) -> Result<ClusterId, PlanError>

Determine the cluster ID to use for this item.

If in_cluster is None we will update it to refer to the default cluster. Because of this, do not normalize/canonicalize the create SQL statement until after calling this function.