Struct MetadataRegistry 

pub struct MetadataRegistry {
    pub tables: Arc<DashMap<String, Arc<TableMeta>>>,
}

글로벌 파티션 및 스토리지 계층 상태 캐시 시스템. LifecycleWorker 가 동기화하며 Optimizer와 분산 스케줄러가 구독합니다.

Fields

tables: Arc<DashMap<String, Arc<TableMeta>>>

Implementations

impl MetadataRegistry

pub fn new() -> Self

pub fn get_table(&self, table_name: &str) -> Option<Arc<TableMeta>>

pub fn register_table(&self, table_name: String, schema: Arc<Schema>)

pub fn update_partition( &self, table_name: &str, partition_id: String, meta: PartitionMeta, )

특정 파티션의 위치와 계층 상태를 업데이트합니다. LifecycleWorker 컴팩션 이후 호출됩니다.

pub fn drop_partition(&self, table_name: &str, partition_id: &str)

해당 파티션을 스캔 범위에서 완전 제거합니다. (삭제나 Time Travel, 만료 등으로 파기될 때)

Trait Implementations

impl Clone for MetadataRegistry

fn clone(&self) -> MetadataRegistry

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for MetadataRegistry

fn default() -> Self

Returns the “default value” for a type.