Skip to content

Commit

Permalink
lint
Browse files Browse the repository at this point in the history
  • Loading branch information
rok committed Mar 5, 2025
1 parent 2467728 commit 2b6b5bb
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 5 deletions.
7 changes: 4 additions & 3 deletions parquet/src/arrow/arrow_writer/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -1280,11 +1280,12 @@ mod tests {
#[cfg(feature = "encryption")]
use crate::arrow::arrow_reader::tests::verify_encryption_test_file_read;
#[cfg(feature = "encryption")]
use crate::arrow::arrow_reader::ArrowReaderMetadata;
#[cfg(feature = "encryption")]
use crate::arrow::arrow_reader::ArrowReaderOptions;
use crate::arrow::arrow_reader::{
ArrowReaderMetadata, ParquetRecordBatchReader, ParquetRecordBatchReaderBuilder,
};
use crate::arrow::arrow_reader::{ParquetRecordBatchReader, ParquetRecordBatchReaderBuilder};
use crate::arrow::ARROW_SCHEMA_META_KEY;
#[cfg(feature = "encryption")]
use crate::encryption::encrypt::EncryptionKey;
use arrow::datatypes::ToByteSlice;
use arrow::datatypes::{DataType, Schema};
Expand Down
4 changes: 2 additions & 2 deletions parquet/src/encryption/encrypt.rs
Original file line number Diff line number Diff line change
Expand Up @@ -172,11 +172,11 @@ impl FileEncryptor {

pub(crate) fn get_column_encryptor(&self, column_path: &Vec<u8>) -> RingGcmBlockEncryptor {
if self.properties.column_keys.is_empty() {
return RingGcmBlockEncryptor::new(&self.properties.footer_key.key());
return RingGcmBlockEncryptor::new(self.properties.footer_key.key());
}
match self.properties.column_keys.get(column_path) {
None => todo!("Handle unencrypted columns"),
Some(column_key) => RingGcmBlockEncryptor::new(&column_key.key())
Some(column_key) => RingGcmBlockEncryptor::new(column_key.key())
}
}
}
Expand Down

0 comments on commit 2b6b5bb

Please sign in to comment.