()
| 113 | } |
| 114 | |
| 115 | fn get_ctx() -> Arc<SessionContext> { |
| 116 | let rt = RuntimeEnvBuilder::new() |
| 117 | .with_disk_manager_builder( |
| 118 | DiskManagerBuilder::default().with_mode(DiskManagerMode::Disabled), |
| 119 | ) |
| 120 | .build_arc() |
| 121 | .unwrap(); |
| 122 | let session_config = SessionConfig::new().with_target_partitions(1); |
| 123 | Arc::new(SessionContext::new_with_config_rt(session_config, rt)) |
| 124 | } |
| 125 | |
| 126 | fn create_test_data() -> (Arc<Schema>, RecordBatch) { |
| 127 | let schema = Arc::new(Schema::new(vec![ |
searching dependent graphs…