MCPcopy Create free account
hub / github.com/apache/datafusion / register_deregister

Function register_deregister

datafusion/core/src/execution/context/mod.rs:2444–2456  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

2442
2443 #[tokio::test]
2444 async fn register_deregister() -> Result<()> {
2445 let tmp_dir = TempDir::new()?;
2446 let partition_count = 4;
2447 let ctx = create_ctx(&tmp_dir, partition_count).await?;
2448
2449 let provider = test::create_table_dual();
2450 ctx.register_table("dual", provider)?;
2451
2452 assert!(ctx.deregister_table("dual")?.is_some());
2453 assert!(ctx.deregister_table("dual")?.is_none());
2454
2455 Ok(())
2456 }
2457
2458 #[tokio::test]
2459 async fn send_context_to_threads() -> Result<()> {

Callers

nothing calls this directly

Calls 4

newFunction · 0.85
create_ctxFunction · 0.85
create_table_dualFunction · 0.85
register_tableMethod · 0.45

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…