// Licensed to the Apache Software Foundation (ASF) under one // or more contributor license agreements. See the NOTICE file // distributed with this work for additional information // regarding copyright ownership. The ASF licenses this file // to you under the Apache License, Version 2.0 (the // "License"); you may not use this file except in compliance // with the License. You may obtain a copy of the License at // // http://www.apache.org/licenses/LICENSE-2.0 // // Unless required by applicable law or agreed to in writing, // software distributed under the License is distributed on an // "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. #include "udf_sample.h" namespace doris_udf { // --------------------------------------------------------------------------- // This is a sample of implementing a COUNT aggregate function. // --------------------------------------------------------------------------- void CountInit(FunctionContext* context, BigIntVal* val) { val->is_null = false; val->val = 0; } void CountUpdate(FunctionContext* context, const IntVal& input, BigIntVal* val) { if (input.is_null) return; ++val->val; } void CountMerge(FunctionContext* context, const BigIntVal& src, BigIntVal* dst) { dst->val += src.val; } BigIntVal CountFinalize(FunctionContext* context, const BigIntVal& val) { return val; } }