File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -372,7 +372,7 @@ impl Iterator for NaiveStripeDecoder {
372372 if self . index < self . number_of_rows {
373373 // Handle row selection if present
374374 if self . row_selection . is_some ( ) {
375- return self . next_with_row_selection ( ) ;
375+ self . next_with_row_selection ( )
376376 } else {
377377 // No row selection - decode normally
378378 let record = self
Original file line number Diff line number Diff line change @@ -21,11 +21,13 @@ use std::fs::File;
2121
2222use arrow:: record_batch:: RecordBatch ;
2323use arrow:: util:: pretty;
24- use futures_util:: stream:: TryStreamExt ;
2524use orc_rust:: arrow_reader:: ArrowReaderBuilder ;
2625use orc_rust:: projection:: ProjectionMask ;
2726use orc_rust:: row_selection:: { RowSelection , RowSelector } ;
2827
28+ #[ cfg( feature = "async" ) ]
29+ use futures_util:: stream:: TryStreamExt ;
30+
2931fn basic_path ( path : & str ) -> String {
3032 let dir = env ! ( "CARGO_MANIFEST_DIR" ) ;
3133 format ! ( "{dir}/tests/basic/data/{path}" )
You can’t perform that action at this time.
0 commit comments