mz_sql::plan::statement::ddl

Function source_sink_cluster_config

Source 
fn source_sink_cluster_config<'a, 'ctx>(
    scx: &'a StatementContext<'ctx>,
    in_cluster: &mut Option<ResolvedClusterName>,
) -> Result<&'a dyn CatalogCluster<'ctx>, PlanError>
Expand description

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.