fn plan_sink(
scx: &StatementContext<'_>,
stmt: CreateSinkStatement<Aug>,
) -> Result<Plan, PlanError>
Expand description
This function will plan a sink as if it does not exist in the catalog. This is so the planning logic is reused by both CREATE SINK and ALTER SINK planning. It is the responsibility of the callers (plan_create_sink and plan_alter_sink) to check for name collisions if this is important.