File tree Expand file tree Collapse file tree 1 file changed +10
-4
lines changed
parquet/src/util/test_common Expand file tree Collapse file tree 1 file changed +10
-4
lines changed Original file line number Diff line number Diff line change @@ -102,18 +102,24 @@ pub fn verify_encryption_test_file_read(
102102}
103103
104104#[ cfg( feature = "encryption" ) ]
105- pub fn read_and_roundtrip_to_encrypted_file ( path : & str , decryption_properties : FileDecryptionProperties , encryption_properties : FileEncryptionProperties ) {
105+ pub fn read_and_roundtrip_to_encrypted_file (
106+ path : & str ,
107+ decryption_properties : FileDecryptionProperties ,
108+ encryption_properties : FileEncryptionProperties ,
109+ ) {
106110 let temp_file = tempfile:: tempfile ( ) . unwrap ( ) ;
107111
108112 // read example data
109113 let file = File :: open ( path) . unwrap ( ) ;
110- let options =
111- ArrowReaderOptions :: default ( ) . with_file_decryption_properties ( decryption_properties. clone ( ) ) ;
114+ let options = ArrowReaderOptions :: default ( )
115+ . with_file_decryption_properties ( decryption_properties. clone ( ) ) ;
112116 let metadata = ArrowReaderMetadata :: load ( & file, options. clone ( ) ) . unwrap ( ) ;
113117
114118 let builder = ParquetRecordBatchReaderBuilder :: try_new_with_options ( file, options) . unwrap ( ) ;
115119 let batch_reader = builder. build ( ) . unwrap ( ) ;
116- let batches = batch_reader. collect :: < crate :: errors:: Result < Vec < RecordBatch > , _ > > ( ) . unwrap ( ) ;
120+ let batches = batch_reader
121+ . collect :: < crate :: errors:: Result < Vec < RecordBatch > , _ > > ( )
122+ . unwrap ( ) ;
117123
118124 // write example data
119125 let props = WriterProperties :: builder ( )
You can’t perform that action at this time.
0 commit comments