uqa-execution 0.3.0

Volcano physical operators with row-batch pipelines
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

//
// Unified Query Algebra
//
// Copyright (c) 2023-2026 Cognica, Inc.
//

//! Retained schema generations and catalog publication for stored dependency rewrites.
use super::TableSchemaState;
use crate::catalog::foreign::StoredForeignTable;
use std::collections::BTreeMap;
use uqa_core::RelationIdentity;
use uqa_storage::StorageBackendResult;

pub type LoadedTableSchema<'a> = (String, Box<dyn TableSchemaState + 'a>);
pub trait LoadedTableSchemas {
    fn table_schemas(&self) -> Vec<LoadedTableSchema<'_>>;
}
pub trait ForeignSchemaPublication {
    fn foreign_tables(&self) -> BTreeMap<RelationIdentity, StoredForeignTable>;
    fn persist_foreign_table(
        &self,
        relation: &RelationIdentity,
        table: &StoredForeignTable,
    ) -> StorageBackendResult<()>;
    fn publish_foreign_tables(&self, updates: Vec<(RelationIdentity, StoredForeignTable)>);
}
pub trait CatalogPublicationChanges {
    fn table_catalog_changed(&self);
    fn catalog_registry_changed(&self);
}
pub struct SchemaDependencyPublicationContext<'a> {
    pub tables: &'a dyn LoadedTableSchemas,
    pub foreign: &'a dyn ForeignSchemaPublication,
    pub changes: &'a dyn CatalogPublicationChanges,
}