(pf *parquet.File, opts common.SearchOptions)
| 492 | } |
| 493 | |
| 494 | func rowGroupsFromFile(pf *parquet.File, opts common.SearchOptions) []parquet.RowGroup { |
| 495 | rgs := pf.RowGroups() |
| 496 | if opts.TotalPages > 0 { |
| 497 | // Read UP TO TotalPages. The sharding calculations |
| 498 | // are just estimates, so it may not line up with the |
| 499 | // actual number of pages in this file. |
| 500 | if opts.StartPage+opts.TotalPages > len(rgs) { |
| 501 | opts.TotalPages = len(rgs) - opts.StartPage |
| 502 | } |
| 503 | rgs = rgs[opts.StartPage : opts.StartPage+opts.TotalPages] |
| 504 | } |
| 505 | |
| 506 | return rgs |
| 507 | } |
no outgoing calls
no test coverage detected