Method seek

pkg/parquetquery/iters.go:1378–1417

(iterNum int, d int, t RowNumber)

}

func (j *LeftJoinIterator) seek(iterNum int, d int, t RowNumber) (err error) {
	d = min(d, j.defLevelsRequired[iterNum])
	if EqualRowNumber(d, j.collectedThroughRequired[iterNum], t) {
		// Last collected value still matches.
		return nil
	}

	// Last collected value no longer matches.
	// Look at last peeked value.
	if j.peeksRequired[iterNum] == nil {
		// We don't have a peeked value to seek forward and return regardless of the outcome.
		j.peeksRequired[iterNum], err = j.required[iterNum].SeekTo(t, d)
		if err != nil {
			return
		}
		return nil
	}

	// We have a peeked value so see if it is valid.
	if CompareRowNumbers(d, j.peeksRequired[iterNum].RowNumber, t) >= 0 {
		// Last peeked value still matches or this iter is already higher.
		return nil
	}

	// Nothing matches so we have to seek forward.

	// Release peek if present
	// These results have been collected but never returned upstream,
	// so we know it is safe to release them.
	if j.peeksRequired[iterNum] != nil {
		j.peeksRequired[iterNum].Release()
	}

	j.peeksRequired[iterNum], err = j.required[iterNum].SeekTo(t, d)
	if err != nil {
		return err
	}

	return nil
}

func (j *LeftJoinIterator) seekAllRequired(t RowNumber, d int) (done bool, err error) {
	for iterNum, iter := range j.required {