(
catalog: &Arc<dyn Catalog>,
catalog_name: &str,
args: &HashMap<String, String>,
)
| 250 | } |
| 251 | |
| 252 | async fn get_table( |
| 253 | catalog: &Arc<dyn Catalog>, |
| 254 | catalog_name: &str, |
| 255 | args: &HashMap<String, String>, |
| 256 | ) -> DFResult<Table> { |
| 257 | let table_str = require_arg(args, "table")?; |
| 258 | let identifier = resolve_table_identifier(table_str, catalog_name)?; |
| 259 | catalog |
| 260 | .get_table(&identifier) |
| 261 | .await |
| 262 | .map_err(to_datafusion_error) |
| 263 | } |
| 264 | |
| 265 | fn managers(table: &Table) -> (SnapshotManager, TagManager) { |
| 266 | let sm = SnapshotManager::new(table.file_io().clone(), table.location().to_string()); |
no test coverage detected