Method compileUDFCall

compiler/rungen/expr.go:272–286

(tag string, f *dag.FuncDef)

}

func (b *Builder) compileUDFCall(tag string, f *dag.FuncDef) (expr.Function, error) {
	if fn, ok := b.compiledUDFs[tag]; ok { //XXX this doesn't work for stateful things
		return fn, nil
	}
	fn := expr.NewUDF(b.sctx(), b.funcs[tag].Name, f.Params)
	// We store compiled UDF calls here so as to avoid stack overflows on
	// recursive calls.
	b.compiledUDFs[tag] = fn
	var err error
	if fn.Body, err = b.compileExpr(f.Expr); err != nil {
		return nil, err
	}
	delete(b.compiledUDFs, tag)
	return fn, nil
}

func (b *Builder) compileMapCall(a *dag.MapCallExpr) (expr.Evaluator, error) {
	e, err := b.compileExpr(a.Expr)