pub fn execute_live_table_ddl(
registry: &LiveTableRegistry,
sql: &str,
) -> SqlResult<Option<LogicalPlan>>Expand description
Apply a live-table statement to the registry and return its logical plan.
REFRESH LIVE TABLE <name> looks up the existing query in the
registry and re-registers it (which is the registry-level half of
“refresh” — the executor is expected to re-execute the plan to
materialise the new result). If the named table is not registered,
the refresh is rejected with SqlError::Unsupported so callers see a
clear error rather than a silent no-op.
The registry is &LiveTableRegistry (not &Mutex<...>); internal
synchronisation is the registry’s responsibility. Callers that
already hold a Mutex<LiveTableRegistry> can pass &*guard.