Function
newRowIterator
(r *parquet.Reader, pageFile *pageFile, rowNumbers []common.IDMapEntry[int64], traceIDIndex int)
Source from the content-addressed store, hash-verified
| 933 | } |
| 934 | |
| 935 | func newRowIterator(r *parquet.Reader, pageFile *pageFile, rowNumbers []common.IDMapEntry[int64], traceIDIndex int) *rowIterator { //nolint:all //deprecated |
| 936 | return &rowIterator{ |
| 937 | reader: r, |
| 938 | pageFile: pageFile, |
| 939 | rowNumbers: rowNumbers, |
| 940 | traceIDIndex: traceIDIndex, |
| 941 | } |
| 942 | } |
| 943 | |
| 944 | 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 |
| 945 | if len(i.rowNumbers) == 0 { |
Tested by
no test coverage detected