MCPcopy Create free account
hub / github.com/apache/paimon-rust / register_schema

Method register_schema

crates/integrations/datafusion/src/catalog.rs:150–173  ·  view source on GitHub ↗
(
        &self,
        name: &str,
        _schema: Arc<dyn SchemaProvider>,
    )

Source from the content-addressed store, hash-verified

148 }
149
150 fn register_schema(
151 &self,
152 name: &str,
153 _schema: Arc<dyn SchemaProvider>,
154 ) -> DFResult<Option<Arc<dyn SchemaProvider>>> {
155 let catalog = Arc::clone(&self.catalog);
156 let dynamic_options = Arc::clone(&self.dynamic_options);
157 let name = name.to_string();
158 block_on_with_runtime(
159 async move {
160 catalog
161 .create_database(&name, false, HashMap::new())
162 .await
163 .map_err(to_datafusion_error)?;
164 Ok(Some(Arc::new(PaimonSchemaProvider::new(
165 Arc::clone(&catalog),
166 name,
167 dynamic_options,
168 None,
169 )) as Arc<dyn SchemaProvider>))
170 },
171 "paimon catalog access thread panicked",
172 )
173 }
174
175 fn deregister_schema(
176 &self,

Callers

nothing calls this directly

Calls 2

block_on_with_runtimeFunction · 0.85
create_databaseMethod · 0.45

Tested by

no test coverage detected