Commit 16ec681 1 parent cc76136 commit 16ec681 Copy full SHA for 16ec681
File tree 2 files changed +1
-6
lines changed
2 files changed +1
-6
lines changed Original file line number Diff line number Diff line change @@ -120,7 +120,6 @@ impl RowGroups for InMemoryRowGroup {
120
120
None => Err ( ParquetError :: General ( format ! (
121
121
"Invalid column index {i}, column was not fetched"
122
122
) ) ) ,
123
- // todo: provide crypto_context
124
123
Some ( data) => {
125
124
let page_reader: Box < dyn PageReader > = Box :: new ( SerializedPageReader :: new (
126
125
data. clone ( ) ,
Original file line number Diff line number Diff line change @@ -179,14 +179,11 @@ impl<T: AsyncRead + AsyncSeek + Unpin + Send> AsyncFileReader for T {
179
179
self . take ( metadata_len as _ ) . read_to_end ( & mut buf) . await ?;
180
180
181
181
#[ cfg( feature = "encryption" ) ]
182
- let fd = None ;
183
- // let fd = file_decryption_properties.cloned();
184
-
185
182
Ok ( Arc :: new ( ParquetMetaDataReader :: decode_metadata (
186
183
& buf,
187
184
footer. encrypted_footer ( ) ,
188
185
#[ cfg( feature = "encryption" ) ]
189
- fd ,
186
+ file_decryption_properties ,
190
187
) ?) )
191
188
}
192
189
. boxed ( )
@@ -1050,7 +1047,6 @@ impl RowGroups for InMemoryRowGroup<'_> {
1050
1047
// filter out empty offset indexes (old versions specified Some(vec![]) when no present)
1051
1048
. filter ( |index| !index. is_empty ( ) )
1052
1049
. map ( |index| index[ i] . page_locations . clone ( ) ) ;
1053
- // todo: provide crypto_context
1054
1050
let page_reader: Box < dyn PageReader > = Box :: new ( SerializedPageReader :: new (
1055
1051
data. clone ( ) ,
1056
1052
self . metadata . column ( i) ,
You can’t perform that action at this time.
0 commit comments