Structsยง
- Migrate
Result ๐
Constantsยง
- MIGRATION_
VERSION_ ๐KEY - Catalog key of the
migration_versionsetting.
Functionsยง
- 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
VERSIONqualifier from by-id references to non-user (builtin) items. - 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_
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