Function
newRowIterator
(r *parquet.Reader, pageFile *pageFile, rowNumbers []common.IDMapEntry[int64], traceIDIndex int)
Source from the content-addressed store, hash-verified
| 1027 | } |
| 1028 | |
| 1029 | func newRowIterator(r *parquet.Reader, pageFile *pageFile, rowNumbers []common.IDMapEntry[int64], traceIDIndex int) *rowIterator { //nolint:all //deprecated |
| 1030 | return &rowIterator{ |
| 1031 | reader: r, |
| 1032 | pageFile: pageFile, |
| 1033 | rowNumbers: rowNumbers, |
| 1034 | traceIDIndex: traceIDIndex, |
| 1035 | } |
| 1036 | } |
| 1037 | |
| 1038 | 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 |
| 1039 | if len(i.rowNumbers) == 0 { |
Tested by
no test coverage detected