Function
newRowIterator
(r *parquet.Reader, pageFile *pageFile, rowNumbers []common.IDMapEntry[int64], traceIDIndex int)
Source from the content-addressed store, hash-verified
| 978 | } |
| 979 | |
| 980 | func newRowIterator(r *parquet.Reader, pageFile *pageFile, rowNumbers []common.IDMapEntry[int64], traceIDIndex int) *rowIterator { //nolint:all //deprecated |
| 981 | return &rowIterator{ |
| 982 | reader: r, |
| 983 | pageFile: pageFile, |
| 984 | rowNumbers: rowNumbers, |
| 985 | traceIDIndex: traceIDIndex, |
| 986 | } |
| 987 | } |
| 988 | |
| 989 | func (i *rowIterator) peekNextID(context.Context) (common.ID, error) { //nolint:unused //this is being marked as unused, but it's required to satisfy the bookmarkIterator interface |
| 990 | if len(i.rowNumbers) == 0 { |
Tested by
no test coverage detected