Function compileAggFunction

server/functions/framework/catalog.go:195–215

compileNonOperatorFunction creates a CompiledFunction for each overload of the given function.

(funcName string, overloads []AggregateFunctionInterface)

// compileNonOperatorFunction creates a CompiledFunction for each overload of the given function.
func compileAggFunction(funcName string, overloads []AggregateFunctionInterface) {
	var newBuffer NewBufferFn
	overloadTree := NewOverloads()
	for _, functionOverload := range overloads {
		newBuffer = functionOverload.NewBuffer
		if err := overloadTree.Add(functionOverload); err != nil {
			panic(err)
		}
	}

	// Store the compiled function into the engine's built-in functions
	// TODO: don't do this, use an actual contract for communicating these functions to the engine catalog
	createFunc := func(ctx *sql.Context, params ...sql.Expression) (sql.Expression, error) {
		return NewCompiledAggregateFunction(ctx, funcName, params, overloadTree, newBuffer), nil
	}
	function.BuiltIns = append(function.BuiltIns, sql.FunctionN{
		Name: funcName,
		Fn:   createFunc,
	})
	compiledCatalog[funcName] = createFunc
}

// compileFunctions creates a CompiledFunction for each overload of each function in the catalog.
func compileFunctions() {