fn source_sink_cluster_config(
scx: &StatementContext<'_>,
ty: &'static str,
in_cluster: &mut Option<ResolvedClusterName>,
) -> Result<ClusterId, 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.