(
&self,
name: &str,
_schema: Arc<dyn SchemaProvider>,
)
| 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, |
nothing calls this directly
no test coverage detected