AddFuncGroup(    "generate_series", 8,    AddBuiltinFunc(_0(938), _1("generate_series"), ..., _5(generate_series_timestamp), ..., _20(3, 1114, 1114, 1186), ..., _25("generate_series_timestamp"), ...),    AddBuiltinFunc(_0( 939), _1("generate_series"),..., _5(generate_series_timestamptz),  ..._20(3, 1184, 1184, 1186), ..., _25("generate_series_timestamptz"), ...),    AddBuiltinFunc(_0(1066), _1("generate_series"),...,_5(generate_series_step_int4),..., _20(3, 23, 23, 23), ..., _25("generate_series_step_int4"),...),    ...),

openGauss=# \df concat_ws                                               List of functions   Schema   |   Name    | Result data type | Argument data types  |  Type  | fencedmode | propackage | prokind------------+-----------+------------------+----------------------+--------+------------+------------+--------- pg_catalog | concat_ws | text             | text, VARIADIC "any" | normal | f          | f          | f(1 row)

openGauss=# \df pg_start_backup                                                             List of functions   Schema   |      Name       | Result data type |             Argument data types             |  Type  | fencedmode | propackage | prokind------------+-----------------+------------------+---------------------------------------------+--------+------------+------------+--------- pg_catalog | pg_start_backup | text             | label text, fast boolean DEFAULT false      | normal | f          | f          | f pg_catalog | pg_start_backup | text             | label text, fast boolean, exclusive boolean | normal | f          | f          | f(2 rows)

Datum pg_terminate_session(PG_FUNCTION_ARGS){    ThreadId tid = PG_GETARG_INT64(0);    uint64 sid = PG_GETARG_INT64(1);    int r = -1;
    if (tid == sid) {        r = kill_backend(tid);    } else if (ENABLE_THREAD_POOL) {        ThreadPoolSessControl *sess_ctrl = g_threadPoolControler->GetSessionCtrl();        int ctrl_idx = sess_ctrl->FindCtrlIdxBySessId(sid);        r = sess_ctrl->SendSignal((int)ctrl_idx, SIGTERM);    }
    PG_RETURN_BOOL(r == 0);}

Datum gs_threadpool_status(PG_FUNCTION_ARGS){    FuncCallContext* funcctx = NULL;   // 函数调用上下文    ThreadPoolStat* entry = NULL;      // 用于保存单行的值    ...
    // 第一次调用需要提前初始化函数调用上下文的相关信息。    if (SRF_IS_FIRSTCALL()) {        // 在fcinfo中创建函数调用上下文        funcctx = SRF_FIRSTCALL_INIT();
        // 初始化列描述信息，并保存到函数调用上下文。        TupleDesc tupdesc = CreateTemplateTupleDesc(NUM_THREADPOOL_STATUS_ELEM, false, TAM_HEAP);        TupleDescInitEntry(tupdesc, (AttrNumber)1, "nodename", TEXTOID, -1, 0);        TupleDescInitEntry(tupdesc, (AttrNumber)2, "groupid", INT4OID, -1, 0);        ....        funcctx->tuple_desc = BlessTupleDesc(tupdesc);
        /* 计算总行数，并获取所有源数据 */        funcctx->user_fctx = (void*)g_threadPoolControler->GetThreadPoolStat(&(funcctx->max_calls));    }
    // 在fcinfo中找到函数调用上下文。    funcctx = SRF_PERCALL_SETUP();
    // 调用计数 < 总行数    if (funcctx->call_cntr < funcctx->max_calls) {        Datum values[NUM_THREADPOOL_STATUS_ELEM];        bool nulls[NUM_THREADPOOL_STATUS_ELEM] = {false};
        // 在上下文中找到当前行的源数据        entry = (((ThreadPoolStat*)funcctx->user_fctx) + funcctx->call_cntr);
        // 将当前行源数据填充到values、nulls数组中，并form成一个tuple。        values[0] = CStringGetTextDatum(g_instance.attr.attr_common.PGXCNodeName);        nulls[0] = false;        values[1] = Int32GetDatum(entry->groupId);        ...        HeapTuple tuple = heap_form_tuple(funcctx->tuple_desc, values, nulls);
        // 返回当前行，并标注还会有下一行，同时将调用计数加一。后续还会继续调用此函数获取数据。        SRF_RETURN_NEXT(funcctx, HeapTupleGetDatum(tuple));    } else {        // 返回空，并标注当前已经返回所有行了。后续不会再调用此函数获取数据了        SRF_RETURN_DONE(funcctx);    }}

/* hard-wired binary version number */const uint32 GRAND_VERSION_NUM = 92423;

-- 首先需要先DROP一下，防止例如我们第一次升级意外失败，残留数据没回滚干净又升了第二次等函数早就存在了的情况DROP FUNCTION IF EXISTS pg_catalog.new_function_name(text, text) CASCADE;
-- 设置下一个创建对象的OID，此处0000要替换成我们这个函数的oid。SET LOCAL inplace_upgrade_next_system_object_oids=IUO_PROC, 0000;
-- 创建函数。-- 类似通过PLPGSQL创建函数语法，但区别在于AS后并不是类似 "$$...begin...end $$"的函数体，而直接直接指定了其底层功能实现函数的函数名，同时LANGUAGE也不是plpgsql, 而是设置为internal。-- 其余的部分与plpgsql就一致了，如returns、各种属性指定方式等。CREATE FUNCTION pg_catalog.new_function_name(text, text)RETURNS int8as 'cfunc_of_new_function'LANGUAGE INTERNAL IMMUTABLE COST 10000 STRICT;

-- 删除。DROP FUNCTION IF EXISTS pg_catalog.new_function_name(text, text) CASCADE;

openGauss=# select * from pg_aggregate where aggfnoid=2101;    aggfnoid    |   aggtransfn   |   aggcollectfn   | aggfinalfn | aggsortop | aggtranstype | agginitval | agginitcollect | aggkind | aggnumdirectargs----------------+----------------+------------------+------------+-----------+--------------+------------+----------------+---------+------------------ pg_catalog.avg | int4_avg_accum | int8_avg_collect | int8_avg   |         0 |         1016 | {0,0}      | {0,0}          | n       |   0(1 row)

聚集函数也需要有函数身份，因此我们需要像普通函数一样通过builtin_funcs.ini将其注册到pg_proc。但填写时需要注意如下几个值。以avg为例：
AddFuncGroup(    "avg", 8,    AddBuiltinFunc(_0(2100), _1("avg"), _2(1), _3(false), _4(false), _5(aggregate_dummy), _6(1700), _7(PG_CATALOG_NAMESPACE), _8(BOOTSTRAP_SUPERUSERID), _9(INTERNALlanguageId), _10(1), _11(0), _12(0), _13(0), _14(true), _15(false), _16(false), _17(false), _18('i'), _19(0), _20(1, 20), _21(NULL), _22(NULL), _23(NULL), _24(NULL), _25("aggregate_dummy"), _26(NULL), _27(NULL), _28(NULL), _29(0), _30(false), _31(NULL), _32(false), _33(NULL), _34('f'), _35(NULL),  _36(0), _37(false)),    ...)

DATA(insert ( 2101 int4_avg_accum int8_avg_collect int8_avg 0 1016 "{0,0}" "{0,0}" n 0));

-- 先创建阶段函数。json_agg的阶段函数只有两个。DROP FUNCTION IF EXISTS pg_catalog.json_agg_finalfn(internal) CASCADE;SET LOCAL inplace_upgrade_next_system_object_oids = IUO_PROC, 3125;CREATE FUNCTION pg_catalog.json_agg_finalfn ...;DROP FUNCTION IF EXISTS pg_catalog.json_agg_transfn(internal, anyelement) CASCADE;SET LOCAL inplace_upgrade_next_system_object_oids = IUO_PROC, 3126;CREATE FUNCTION pg_catalog.json_agg_transfn ...;
-- 同样先执行drop清理环境，之后设置oid，最后使用CREATE AGGREGATE语句注册聚集函数。drop aggregate if exists pg_catalog.json_agg(anyelement);SET LOCAL inplace_upgrade_next_system_object_oids=IUO_PROC, 3124;create aggregate pg_catalog.json_agg(anyelement)(SFUNC=json_agg_transfn, STYPE= internal, finalfunc = json_agg_finalfn);

-- 先drop聚集函数，在drop阶段函数。drop aggregate if exists pg_catalog.json_object_agg("any", "any");DROP FUNCTION IF EXISTS pg_catalog.json_object_agg_finalfn(internal) CASCADE;DROP FUNCTION IF EXISTS pg_catalog.json_object_agg_transfn(internal, "any", "any") CASCADE;