Module migrate 

Structs

MigrateResult 🔒

Constants

MIGRATION_VERSION_KEY 🔒

Catalog key of the migration_version setting.

Functions

ast_rewrite_add_missing_doc_on_ids 🔒

Add missing item IDs to DOC ON references in CREATE SINK statements.

ast_rewrite_add_missing_index_ids 🔒

Add missing item IDs to the ON clauses of CREATE INDEX statements.

ast_rewrite_create_sink_partition_strategy 🔒

ast_rewrite_kafka_metadata_refresh_intervals 🔒

ast_rewrite_small_commit_intervals 🔒

Planning enforces a 1 second minimum COMMIT INTERVAL, but smaller intervals used to be accepted (and a sub-millisecond one left the sink unable to ever commit). Rewrite any persisted smaller interval to 1s so the sink still plans after an upgrade.

ast_rewrite_sql_server_constraints 🔒

ast_rewrite_strip_builtin_version_pins 🔒

Strips the VERSION qualifier from by-id references to non-user (builtin) items.

ast_rewrite_strip_unsupported_column_collations 🔒

Planning rejects unsupported column collations, but CREATE TABLE used to accept and ignore them. Strip them so the table still plans after an upgrade. The planner never applied them, so the table’s columns are unchanged.

durable_migrate 🔒

Migrations that run only on the durable catalog before any data is loaded into memory.

get_migration_version 🔒

migrate 🔒

Migrates all user items and loads them into state.

migrate_builtin_tables_to_mvs 🔒

Update system object mappings for builtins whose type changed from table to materialized view.

rewrite_ast_items 🔒

rewrite_doc_on_ids 🔒

Replaces every bare DOC ON reference in stmt for which lookup returns an id with the [id AS name] form. None leaves the reference as a name.

rewrite_interval_option_floor_1s 🔒

Rewrites an interval option value to '1s' if it is below 1 second.

rewrite_items 🔒

rewrite_sources_to_tables 🔒

Migrates all sources to use the new sources as tables model

set_migration_version 🔒