Skip to content

Commit ce21a48

Browse files
corwinjoyrok
authored andcommitted
Attempt to add decryption to ArrowReaderMetadata::load_async
1 parent afe6658 commit ce21a48

File tree

2 files changed

+12
-0
lines changed

2 files changed

+12
-0
lines changed

parquet/src/arrow/async_reader/mod.rs

+4
Original file line numberDiff line numberDiff line change
@@ -72,6 +72,10 @@ use crate::encryption::decryption::CryptoContext;
7272
#[cfg(feature = "object_store")]
7373
pub use store::*;
7474

75+
#[cfg(feature = "encryption")]
76+
use crate::encryption::decryption::{FileDecryptionProperties};
77+
use crate::encryption::decryption::FileDecryptor;
78+
7579
/// The asynchronous interface used by [`ParquetRecordBatchStream`] to read parquet files
7680
///
7781
/// Notes:

parquet/src/file/metadata/mod.rs

+8
Original file line numberDiff line numberDiff line change
@@ -303,6 +303,14 @@ impl ParquetMetaData {
303303
pub(crate) fn set_offset_index(&mut self, index: Option<ParquetOffsetIndex>) {
304304
self.offset_index = index;
305305
}
306+
307+
308+
#[cfg(feature = "encryption")]
309+
/// Set File decryptor
310+
pub(crate) fn set_file_decryptor(&mut self, decryptor: Option<FileDecryptor>) {
311+
self.file_decryptor = decryptor;
312+
}
313+
306314
}
307315

308316
/// A builder for creating / manipulating [`ParquetMetaData`]

0 commit comments

Comments
 (0)