sum_aggregate_for_topn.sql

CREATE AGGREGATE sum(jsonb)(
        SFUNC = topn_union_trans,
        STYPE = internal,
        FINALFUNC = topn_pack
);

CREATE AGGREGATE sum(text)(
        SFUNC = topn_add_trans,
        STYPE = internal,
        FINALFUNC = topn_pack
);


SELECT run_command_on_workers($cmd$CREATE AGGREGATE sum(jsonb)(
        SFUNC = topn_union_trans,
        STYPE = internal,
        FINALFUNC = topn_pack
);$cmd$);

SELECT run_command_on_workers($cmd$CREATE AGGREGATE sum(text)(
        SFUNC = topn_add_trans,
        STYPE = internal,
        FINALFUNC = topn_pack
);$cmd$);