We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3752952 commit d1f18edCopy full SHA for d1f18ed
sql/rowexec/join_iters.go
@@ -185,7 +185,7 @@ func (i *joinIter) Next(ctx *sql.Context) (sql.Row, error) {
185
}
186
187
i.foundMatch = true
188
-
+
189
// For semi joins, close secondary iterator and move to next primary row after first match
190
// This ensures each primary row is emitted at most once (semi join semantics)
191
if i.joinType.IsSemi() {
@@ -198,7 +198,7 @@ func (i *joinIter) Next(ctx *sql.Context) (sql.Row, error) {
198
// For semi joins, return only the primary row, not the combined row
199
return i.removeParentRow(i.buildRow(primary, nil)), nil
200
201
202
return i.removeParentRow(row), nil
203
204
0 commit comments