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

Method cleanup

benchmarks/src/sql_benchmark.rs:377–389  ·  view source on GitHub ↗

Runs `cleanup` queries to reset state after the benchmark run.

(&mut self, ctx: &SessionContext)

Source from the content-addressed store, hash-verified

375
376 /// Runs `cleanup` queries to reset state after the benchmark run.
377 pub async fn cleanup(&mut self, ctx: &SessionContext) -> Result<()> {
378 info!("Running cleanup...");
379
380 let cleanup_queries = self.queries.get(&QueryDirective::Cleanup);
381
382 if let Some(queries) = cleanup_queries {
383 for query in queries {
384 let _ = ctx.sql(query).await?.collect().await?;
385 }
386 }
387
388 Ok(())
389 }
390
391 async fn load_expected_result_files(&mut self, ctx: &SessionContext) -> Result<()> {
392 for query in &mut self.result_queries {

Callers 3

sqlFunction · 0.80

Calls 3

collectMethod · 0.80
sqlMethod · 0.80
getMethod · 0.45

Tested by

no test coverage detected