Expand description
Data definition language (DDL).
This module houses the handlers for statements that modify the catalog, like
ALTER
, CREATE
, and DROP
.
Modules§
- connection πData definition language (DDL) utilities for CONNECTION objects.
Structs§
- Creating this by hand instead of using generate_extracted_config! macro because the macro doesnβt support parameterized enums. See https://github.com/MaterializeInc/database-issues/issues/6698
Enums§
Constants§
- MAX_
NUM_ πCOLUMNS
Functions§
- alter_
retain_ πhistory - check_
partition_ πby Given a relation desc and a column list, checks that: - Returns
true
if the cluster has any storage object. Returnfalse
if the cluster has no objects. - continual_
task_ πquery - Does the dependency
dep
prevent a drop of a non-cascade query? - Returns an error if the given cluster is a managed cluster
- get_
encoding π - get_
encoding_ πinner - get_
key_ πenvelope Extract the key envelope, if it is requested - Gets the key envelope for a given key encoding when no name for the key has been requested by the user.
- kafka_
sink_ πbuilder - key_
constraint_ πerr - Convert a
ClusterScheduleOptionValue
into aClusterSchedule
. - Convert a
CreateClusterStatement
into aPlan
. - plan_
drop_ πcluster - plan_
drop_ πdatabase - plan_
drop_ πitem Returns theCatalogItemId
of the item we should drop, if it exists. - plan_
drop_ πrole - plan_
drop_ πschema - plan_
index_ πoptions - plan_
replica_ πconfig - plan_
retain_ πhistory - plan_
role_ πattributes - plan_
role_ πvariable - plan_
sink π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. - Plans the RelationDesc for a source export (subsource or table) that has a defined list of columns and constraints.
- plan_
table_ πoptions - resolve_
cluster π - resolve_
database π - resolve_
item_ πor_ type - resolve_
schema π - Determine the cluster ID to use for this item.
- typecheck_
debezium π - Convert a
ClusterSchedule
into aClusterScheduleOptionValue
. - Convert a
CreateClusterPlan
into aCreateClusterStatement
.