Skip to main content

apply_migration

Function apply_migration 

Source
async fn apply_migration(
    unopened_catalog_state: &mut PersistHandle<StateUpdateKindJson, UnopenedCatalogStateInner>,
    updates: Vec<(StateUpdateKindJson, Diff)>,
    commit_ts: Timestamp,
) -> Result<Timestamp, CatalogError>
Expand description

Applies one migration’s updates at commit_ts and returns the new upper.