Method exec

runtime/vam/op/cachedsubquery.go:30–49

exec executes c.body and returns a vector of length 1.

()

// exec executes c.body and returns a vector of length 1.
func (c *cachedSubquery) exec() vector.Any {
	var vecs []vector.Any
	for {
		vec, err := c.body.Pull(false)
		if err != nil {
			return vector.NewStringError(c.sctx, err.Error(), 1)
		}
		if vec == nil {
			break
		}
		vecs = append(vecs, vec)
	}
	if len(vecs) == 0 {
		return vector.NewNull(1)
	}
	if len(vecs) == 1 && vecs[0].Len() == 1 {
		return vecs[0]
	}
	return c.newArray(c.vectorConcat(vecs))
}

// newArray returns a vector whose single element is an array of elems.
func (c *cachedSubquery) newArray(elems vector.Any) vector.Any {