Create a test table registered to a session context with an associated cache factory
()
| 338 | |
| 339 | /// Create a test table registered to a session context with an associated cache factory |
| 340 | pub async fn test_table_with_cache_factory() -> Result<DataFrame> { |
| 341 | let session_state = SessionStateBuilder::new() |
| 342 | .with_cache_factory(Some(Arc::new(TestCacheFactory {}))) |
| 343 | .build(); |
| 344 | let ctx = SessionContext::new_with_state(session_state); |
| 345 | let name = "aggregate_test_100"; |
| 346 | register_aggregate_csv(&ctx, name).await?; |
| 347 | ctx.table(name).await |
| 348 | } |
no test coverage detected
searching dependent graphs…