(iterNum int)
| 1127 | } |
| 1128 | |
| 1129 | func (j *JoinIterator) peek(iterNum int) (*IteratorResult, error) { |
| 1130 | var err error |
| 1131 | if j.peeks[iterNum] == nil { |
| 1132 | j.peeks[iterNum], err = j.iters[iterNum].Next() |
| 1133 | if err != nil { |
| 1134 | return nil, err |
| 1135 | } |
| 1136 | } |
| 1137 | return j.peeks[iterNum], nil |
| 1138 | } |
| 1139 | |
| 1140 | // Collect data from the given iterators until they point at |
| 1141 | // the next row (according to the configured definition level) |