File tree Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Original file line number Diff line number Diff line change @@ -175,8 +175,9 @@ impl ArrowReader {
175175        row_group_filtering_enabled :  bool , 
176176        row_selection_enabled :  bool , 
177177    )  -> Result < ArrowRecordBatchStream >  { 
178-         let  should_load_page_index =
179-             ( row_selection_enabled && task. predicate . is_some ( ) )  || !task. deletes . is_empty ( ) ; 
178+         let  should_load_page_index = ( row_selection_enabled && task. predicate . is_some ( ) ) 
179+             || !task. deletes . is_empty ( ) 
180+             || task. limit . is_some ( ) ; 
180181
181182        // concurrently retrieve delete files and create RecordBatchStreamBuilder 
182183        let  ( _,  mut  record_batch_stream_builder)  = try_join ! ( 
@@ -341,7 +342,7 @@ impl ArrowReader {
341342        // Create the record batch stream builder, which wraps the parquet file reader 
342343        let  record_batch_stream_builder = ParquetRecordBatchStreamBuilder :: new_with_options ( 
343344            parquet_file_reader, 
344-             ArrowReaderOptions :: new ( ) , 
345+             ArrowReaderOptions :: new ( ) . with_page_index ( should_load_page_index ) , 
345346        ) 
346347        . await ?; 
347348        Ok ( record_batch_stream_builder) 
 
 
   
 
     
   
   
          
    
    
     
    
      
     
     
    You can’t perform that action at this time.
  
 
    
  
    
      
        
     
       
      
     
   
 
    
    
  
 
  
 
     
    
0 commit comments