Skip to content

Commit c12bc46

Browse files
committed
cache meta
1 parent 0d6b5ff commit c12bc46

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

datafusion/datasource-parquet/src/file_format.rs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1004,7 +1004,6 @@ pub async fn fetch_parquet_metadata(
10041004
let fetch = ObjectStoreFetch::new(store, meta);
10051005

10061006
let reader = ParquetMetaDataReader::new().with_prefetch_hint(size_hint);
1007-
10081007
#[cfg(feature = "parquet_encryption")]
10091008
let reader = reader.with_decryption_properties(decryption_properties);
10101009

@@ -1015,9 +1014,10 @@ pub async fn fetch_parquet_metadata(
10151014

10161015
if cache_metadata {
10171016
if let Some(cache) = file_metadata_cache {
1018-
let cached_metadata =
1019-
Arc::new(CachedParquetMetaData::new(Arc::new(metadata.clone())));
1020-
cache.put(meta, cached_metadata);
1017+
cache.put(
1018+
meta,
1019+
Arc::new(CachedParquetMetaData::new(Arc::new(metadata.clone()))),
1020+
);
10211021
}
10221022
}
10231023

0 commit comments

Comments
 (0)