Add changes needed to access encryption from datafusion.

Author: corwinjoy

parquet/src/arrow/async_reader/mod.rs

@@ -178,11 +178,15 @@ impl<T: AsyncRead + AsyncSeek + Unpin + Send> AsyncFileReader for T {
             let mut buf = Vec::with_capacity(metadata_len);
             self.take(metadata_len as _).read_to_end(&mut buf).await?;
 
+            #[cfg(feature = "encryption")]
+            let fd = None;
+            // let fd = file_decryption_properties.cloned();
+
             Ok(Arc::new(ParquetMetaDataReader::decode_metadata(
                 &buf,
                 footer.encrypted_footer(),
                 #[cfg(feature = "encryption")]
-                file_decryption_properties,
+                fd,
             )?))
         }
         .boxed()

parquet/src/encryption/encryption.rs

@@ -19,10 +19,10 @@ use std::collections::HashMap;
 
 #[derive(Debug, Clone)]
 pub struct FileEncryptionProperties {
-    encrypt_footer: bool,
-    footer_key: Vec<u8>,
-    column_keys: Option<HashMap<Vec<u8>, Vec<u8>>>,
-    aad_prefix: Option<Vec<u8>>,
+    pub encrypt_footer: bool,
+    pub footer_key: Vec<u8>,
+    pub column_keys: Option<HashMap<Vec<u8>, Vec<u8>>>,
+    pub aad_prefix: Option<Vec<u8>>,
 }
 
 impl FileEncryptionProperties {

parquet/src/file/properties.rs

@@ -289,6 +289,11 @@ impl WriterProperties {
         self.statistics_truncate_length
     }
 
+    // Return the encryption properties
+    pub fn file_encryption_properties(&self) -> Option<&FileEncryptionProperties> {
+        self.file_encryption_properties.as_ref()
+    }
+
     /// Returns `true` if type coercion is enabled.
     pub fn coerce_types(&self) -> bool {
         self.coerce_types
@@ -372,6 +377,7 @@ impl WriterProperties {
             .and_then(|c| c.bloom_filter_properties())
             .or_else(|| self.default_column_properties.bloom_filter_properties())
     }
+
 }
 
 /// Builder for  [`WriterProperties`] parquet writer configuration.