WIP: Implement AsyncFileReader

Author: srh

rust/cubestore/cubestore/src/queryplanner/metadata_cache.rs

@@ -2,6 +2,7 @@ use bytes::Bytes;
 use datafusion::datasource::physical_plan::parquet::DefaultParquetFileReaderFactory;
 use datafusion::datasource::physical_plan::{FileMeta, ParquetFileReaderFactory};
 use datafusion::parquet::arrow::async_reader::AsyncFileReader;
+use datafusion::parquet::file::encryption::ParquetEncryptionConfig;
 use datafusion::parquet::file::metadata::ParquetMetaData;
 use datafusion::physical_plan::metrics::ExecutionPlanMetricsSet;
 use futures_util::future::BoxFuture;
@@ -148,14 +149,16 @@ impl AsyncFileReader for LruCachingFileReader {
 
     fn get_metadata(
         &mut self,
+        encryption_config: &Option<ParquetEncryptionConfig>
     ) -> BoxFuture<'_, datafusion::parquet::errors::Result<Arc<ParquetMetaData>>> {
         let cache = self.cache.clone();
         let path = self.path.clone();
+        let encryption_config = encryption_config.clone();
         async move {
             match cache.get(&path) {
                 Some(metadata) => Ok(metadata),
                 None => {
-                    let metadata = self.reader.get_metadata().await?;
+                    let metadata = self.reader.get_metadata(&encryption_config).await?;
                     cache.insert(path, metadata.clone());
                     Ok(metadata)
                 }