// Sub-plan execution for CALL { } subqueries (the per-row lateral-join // sinks live in stream.go).
package exec import ( ) // runSubplan runs a sub-plan over one seed row, combining its UNION // branches exactly like the top-level Execute. func runSubplan( *eval.Ctx, *plan.Plan, []value.Value) [][]value.Value { := runBranchSeeded(, .Branches[0], ) for , := range .Union { combineUnion(&, runBranchSeeded(, .Branches[+1], ), ) } return } // runBranchSeeded runs a branch's segment pipeline from one seed row. // Sub-plans are never profiled (a CALL {} stage records a single output // count, matching the Rust engine). func runBranchSeeded( *eval.Ctx, []*plan.Segment, []value.Value) [][]value.Value { := [][]value.Value{} for , := range { = runSegment(, , , nil) } return }