|
16 | 16 | // under the License. |
17 | 17 |
|
18 | 18 | use crate::cache::CacheAccessor; |
19 | | -use crate::cache::cache_manager::{CachedFileMetadata, FileMetadataCache, FileStatisticsCache, FileStatisticsCacheEntry}; |
| 19 | +use crate::cache::cache_manager::{ |
| 20 | + CachedFileMetadata, FileMetadataCache, FileStatisticsCache, FileStatisticsCacheEntry, |
| 21 | +}; |
| 22 | +use object_store::path::Path; |
20 | 23 | use std::collections::HashMap; |
21 | 24 | use std::sync::Mutex; |
22 | 25 |
|
23 | 26 | pub use crate::cache::DefaultFilesMetadataCache; |
24 | 27 | use crate::cache::lru_queue::LruQueue; |
25 | 28 | use datafusion_common::heap_size::DFHeapSize; |
26 | | -use object_store::path::Path; |
27 | 29 |
|
28 | 30 | /// Default implementation of [`FileStatisticsCache`] |
29 | 31 | /// |
@@ -548,7 +550,10 @@ mod tests { |
548 | 550 | let (meta_2, value_2) = create_cached_file_metadata_with_stats("test2.parquet"); |
549 | 551 | let (meta_3, value_3) = create_cached_file_metadata_with_stats("test3.parquet"); |
550 | 552 |
|
551 | | - let limit_for_2_entries = &meta_1.location.heap_size() + value_1.heap_size() + &meta_2.location.heap_size() + value_2.heap_size(); |
| 553 | + let limit_for_2_entries = &meta_1.location.heap_size() |
| 554 | + + value_1.heap_size() |
| 555 | + + &meta_2.location.heap_size() |
| 556 | + + value_2.heap_size(); |
552 | 557 |
|
553 | 558 | // create a cache with a limit which fits exactly 2 entries |
554 | 559 | let cache = DefaultFileStatisticsCache::new(limit_for_2_entries); |
@@ -580,7 +585,10 @@ mod tests { |
580 | 585 |
|
581 | 586 | cache.remove(&meta_2.location); |
582 | 587 | assert_eq!(cache.len(), 1); |
583 | | - assert_eq!(cache.memory_used(), &meta_3.location.heap_size() + value_3.heap_size()); |
| 588 | + assert_eq!( |
| 589 | + cache.memory_used(), |
| 590 | + &meta_3.location.heap_size() + value_3.heap_size() |
| 591 | + ); |
584 | 592 |
|
585 | 593 | cache.clear(); |
586 | 594 | assert_eq!(cache.len(), 0); |
|
0 commit comments