Skip to content

Commit 45290c0

Browse files
committed
Review feedback
1 parent c775625 commit 45290c0

File tree

1 file changed

+18
-8
lines changed

1 file changed

+18
-8
lines changed

parquet/src/file/metadata/writer.rs

Lines changed: 18 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -153,7 +153,9 @@ impl<'a, W: Write> ThriftMetadataWriter<'a, W> {
153153
schema: types::to_thrift(self.schema.as_ref())?,
154154
created_by: self.created_by.clone(),
155155
column_orders,
156-
encryption_algorithm: self.object_writer.get_footer_encryption_algorithm(),
156+
encryption_algorithm: MetadataObjectWriter::get_footer_encryption_algorithm(
157+
&self.object_writer,
158+
),
157159
footer_signing_key_metadata: None,
158160
};
159161

@@ -502,7 +504,7 @@ impl MetadataObjectWriter {
502504
match self.file_encryptor.as_ref() {
503505
Some(file_encryptor) if file_encryptor.properties().encrypt_footer() => {
504506
// First write FileCryptoMetadata
505-
let crypto_metadata = self.file_crypto_metadata()?;
507+
let crypto_metadata = MetadataObjectWriter::file_crypto_metadata(self)?;
506508
let mut protocol = TCompactOutputProtocol::new(&mut sink);
507509
crypto_metadata.write_to_out_protocol(&mut protocol)?;
508510

@@ -635,8 +637,11 @@ impl MetadataObjectWriter {
635637
}
636638
}
637639

638-
fn get_footer_encryption_algorithm(&self) -> Option<EncryptionAlgorithm> {
639-
if let Some(file_encryptor) = &self.file_encryptor {
640+
fn get_footer_encryption_algorithm(
641+
object_writer: &MetadataObjectWriter,
642+
) -> Option<EncryptionAlgorithm> {
643+
let file_encryptor = object_writer.file_encryptor.as_ref();
644+
if let Some(file_encryptor) = file_encryptor {
640645
let supply_aad_prefix = file_encryptor
641646
.properties()
642647
.aad_prefix()
@@ -655,11 +660,16 @@ impl MetadataObjectWriter {
655660
None
656661
}
657662

658-
fn file_crypto_metadata(&self) -> Result<crate::format::FileCryptoMetaData> {
659-
let properties = self.file_encryptor.as_ref().unwrap().properties();
663+
fn file_crypto_metadata(
664+
object_writer: &MetadataObjectWriter,
665+
) -> Result<crate::format::FileCryptoMetaData> {
666+
let file_encryptor = object_writer.file_encryptor.as_ref().unwrap();
660667
Ok(crate::format::FileCryptoMetaData {
661-
encryption_algorithm: self.get_footer_encryption_algorithm().unwrap(),
662-
key_metadata: properties.footer_key_metadata().cloned(),
668+
encryption_algorithm: MetadataObjectWriter::get_footer_encryption_algorithm(
669+
object_writer,
670+
)
671+
.unwrap(),
672+
key_metadata: file_encryptor.properties().footer_key_metadata().cloned(),
663673
})
664674
}
665675

0 commit comments

Comments
 (0)