Skip to content

Commit 36d7c70

Browse files
committed
minor changes
1 parent b04d042 commit 36d7c70

File tree

1 file changed

+4
-10
lines changed
  • parquet/src/arrow/arrow_writer

1 file changed

+4
-10
lines changed

parquet/src/arrow/arrow_writer/mod.rs

Lines changed: 4 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -3551,10 +3551,9 @@ mod tests {
35513551

35523552
let file = tempfile::tempfile().unwrap();
35533553

3554-
// todo: add encryption
3555-
let key_code: &[u8] = "0123456789012345".as_bytes();
3554+
let footer_key: &[u8] = "0123456789012345".as_bytes();
35563555
let file_encryption_properties =
3557-
FileEncryptionProperties::builder(key_code.to_vec()).build();
3556+
FileEncryptionProperties::builder(footer_key.to_vec()).build();
35583557

35593558
let props = WriterProperties::builder()
35603559
.set_max_row_group_size(200)
@@ -3571,19 +3570,14 @@ mod tests {
35713570

35723571
writer.close().unwrap();
35733572

3574-
// let footer_key = "0123456789012345".as_bytes();
3575-
// let column_key = "1234567890123450".as_bytes();
3576-
let false_key = "1234567890123451".as_bytes();
3577-
3578-
let decryption_properties = FileDecryptionProperties::builder(false_key.to_vec())
3579-
.with_column_key("int".as_bytes().to_vec(), false_key.to_vec())
3573+
let decryption_properties = FileDecryptionProperties::builder(footer_key.to_vec())
3574+
// .with_column_key("int".as_bytes().to_vec(), footer_key.to_vec())
35803575
.build()
35813576
.unwrap();
35823577

35833578
let options =
35843579
ArrowReaderOptions::new().with_file_decryption_properties(decryption_properties);
35853580

3586-
// todo: remove with_file_decryption_properties from things that are not ArrowReaderOptions
35873581
let builder = ParquetRecordBatchReaderBuilder::try_new_with_options(file, options).unwrap();
35883582
assert_eq!(&row_group_sizes(builder.metadata()), &[200, 200, 50]);
35893583

0 commit comments

Comments
 (0)