Build a RuntimeEnv
(self)
| 460 | |
| 461 | /// Build a RuntimeEnv |
| 462 | pub fn build(self) -> Result<RuntimeEnv> { |
| 463 | let Self { |
| 464 | disk_manager, |
| 465 | disk_manager_builder, |
| 466 | memory_pool, |
| 467 | cache_manager, |
| 468 | object_store_registry, |
| 469 | #[cfg(feature = "parquet_encryption")] |
| 470 | parquet_encryption_factory_registry, |
| 471 | } = self; |
| 472 | let memory_pool = |
| 473 | memory_pool.unwrap_or_else(|| Arc::new(UnboundedMemoryPool::default())); |
| 474 | |
| 475 | Ok(RuntimeEnv { |
| 476 | memory_pool, |
| 477 | disk_manager: if let Some(builder) = disk_manager_builder { |
| 478 | Arc::new(builder.build()?) |
| 479 | } else { |
| 480 | #[expect(deprecated)] |
| 481 | DiskManager::try_new(disk_manager)? |
| 482 | }, |
| 483 | cache_manager: CacheManager::try_new(&cache_manager)?, |
| 484 | object_store_registry, |
| 485 | #[cfg(feature = "parquet_encryption")] |
| 486 | parquet_encryption_factory_registry, |
| 487 | }) |
| 488 | } |
| 489 | |
| 490 | /// Convenience method to create a new `Arc<RuntimeEnv>` |
| 491 | pub fn build_arc(self) -> Result<Arc<RuntimeEnv>> { |