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

Function get_table

crates/integrations/datafusion/src/procedures.rs:252–263  ·  view source on GitHub ↗
(
    catalog: &Arc<dyn Catalog>,
    catalog_name: &str,
    args: &HashMap<String, String>,
)

Source from the content-addressed store, hash-verified

250}
251
252async 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
265fn managers(table: &Table) -> (SnapshotManager, TagManager) {
266 let sm = SnapshotManager::new(table.file_io().clone(), table.location().to_string());

Callers 5

proc_create_tagFunction · 0.85
proc_delete_tagFunction · 0.85
proc_rollback_toFunction · 0.85

Calls 3

require_argFunction · 0.85
resolve_table_identifierFunction · 0.85
get_tableMethod · 0.45

Tested by

no test coverage detected