We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 708ada5 commit 0b43242Copy full SHA for 0b43242
2 files changed
datafusion/common/src/heap_size.rs
@@ -170,10 +170,10 @@ impl DFHeapSize for DataType {
170
Struct(s) => s.heap_size(),
171
Union(u, m) => u.heap_size() + m.heap_size(),
172
Dictionary(a, b) => a.heap_size() + b.heap_size(),
173
- Decimal32(u8, i8) => u8.heap_size() + i8.heap_size(),
174
- Decimal64(u8, i8) => u8.heap_size() + i8.heap_size(),
175
- Decimal128(u8, i8) => u8.heap_size() + i8.heap_size(),
176
- Decimal256(u8, i8) => u8.heap_size() + i8.heap_size(),
+ Decimal32(p, s) => p.heap_size() + s.heap_size(),
+ Decimal64(p, s) => p.heap_size() + s.heap_size(),
+ Decimal128(p, s) => p.heap_size() + s.heap_size(),
+ Decimal256(p, s) => p.heap_size() + s.heap_size(),
177
Map(m, b) => m.heap_size() + b.heap_size(),
178
RunEndEncoded(a, b) => a.heap_size() + b.heap_size(),
179
}
datafusion/execution/src/cache/cache_manager.rs
@@ -113,7 +113,7 @@ impl DFHeapSize for CachedFileMetadata {
113
+ self.meta.e_tag.heap_size()
114
+ self.meta.location.as_ref().heap_size()
115
+ self.statistics.heap_size()
116
- //TODO add ordering once LexOrdering /PhysicalExpr implements DFHeapSize
+ //TODO add ordering once LexOrdering/PhysicalExpr implements DFHeapSize
117
118
119
@@ -501,6 +501,7 @@ impl CacheManagerConfig {
501
self
502
503
504
+ /// Specifies the memory limit for the file statistics cache, in bytes.
505
pub fn with_file_statistics_cache_limit(mut self, limit: usize) -> Self {
506
self.file_statistics_cache_limit = limit;
507
0 commit comments