(&self)
| 94 | } |
| 95 | |
| 96 | fn schema_names(&self) -> Vec<String> { |
| 97 | let catalog = Arc::clone(&self.catalog); |
| 98 | block_on_with_runtime( |
| 99 | async move { |
| 100 | catalog.list_databases().await.unwrap_or_else(|e| { |
| 101 | log::error!("failed to list databases: {e}"); |
| 102 | vec![] |
| 103 | }) |
| 104 | }, |
| 105 | "paimon catalog access thread panicked", |
| 106 | ) |
| 107 | } |
| 108 | |
| 109 | fn schema(&self, name: &str) -> Option<Arc<dyn SchemaProvider>> { |
| 110 | let catalog = Arc::clone(&self.catalog); |