Method Call

runtime/vam/expr/function/parse.go:53–84

(args ...vector.Any)

}

func (p *ParseSUP) Call(args ...vector.Any) vector.Any {
	if vec, ok := expr.CheckForNullThenError(args); ok {
		return vec
	}
	vec := vector.Under(args[0])
	if vec.Type().ID() != super.IDString {
		return vector.NewWrappedError(p.sctx, "parse_sup: string arg required", args[0])
	}
	var errs []uint32
	errMsgs := vector.NewStringEmpty(0)
	builder := vector.NewDynamicBuilder()
	for i := range vec.Len() {
		s := vector.StringValue(vec, i)
		p.sr.Reset(s)
		val, err := p.zr.Read()
		if err != nil {
			errs = append(errs, i)
			errMsgs.Append("parse_sup: " + err.Error())
			continue
		}
		if val == nil {
			builder.Write(super.Null)
		} else {
			builder.Write(*val)
		}
	}
	out := builder.Build(p.sctx)
	if len(errs) > 0 {
		return vector.Combine(out, errs, vector.NewVecWrappedError(p.sctx, errMsgs, vector.Pick(args[0], errs)))
	}
	return out
}