如何创建支持ORDER BY表达式参数的Apache Ignite自定义SQL函数？

问题核心原因 #

你写的MYFUN(value ORDER BY time)语法不符合标准SQL自定义函数的参数规则，数据库解析器仅支持普通列、标量表达式或聚合函数结果作为函数参数，带ORDER BY的有序列集合不在默认支持范围内。

可行解决方法 #

1. 定义为自定义聚合函数（推荐） #

如果MYFUN是要对分组内按time排序的value做计算，直接把它定义成自定义聚合函数，而非普通标量函数。聚合函数原生支持在参数中指定ORDER BY，以下是主流数据库的实现思路：

-- PostgreSQL示例：定义带排序支持的聚合函数
CREATE AGGREGATE MYFUN(anyelement, timestamp) (
    SFUNC = myfun_state_func,
    STYPE = myfun_state_type,
    FINALFUNC = myfun_final_func,
    INITCOND = '{}'
);
-- 使用时直接指定排序逻辑
SELECT id, MYFUN(value ORDER BY time) FROM People GROUP BY id;

MySQL、SQL Server等数据库也有对应的自定义聚合函数语法，按照官方规范实现状态转换和最终计算函数即可。

2. 打包有序集合作为参数传入 #

如果数据库支持数组、JSON等集合类型，可先将分组内的(value, time)按time排序后打包成集合，再传给自定义函数：

-- PostgreSQL示例：按time排序后打包成数组
SELECT id, MYFUN(array_agg(value ORDER BY time)) FROM People GROUP BY id;
-- MySQL示例：用JSON_ARRAYAGG排序后传入
SELECT id, MYFUN(JSON_ARRAYAGG(value ORDER BY time)) FROM People GROUP BY id;

这种方式无需修改函数参数定义，只需在函数内部解析集合类型的输入即可。

3. 窗口函数预处理有序数据 #

若场景不需要严格聚合，可先用窗口函数生成按time排序的value序列，再传入自定义函数：

SELECT DISTINCT id, MYFUN(value) OVER (PARTITION BY id ORDER BY time) FROM People;

注意此方式的结果逻辑与聚合查询有差异，需根据实际需求调整。

关于Row、Context参数的说明 #

大部分数据库的自定义函数不支持直接传入Row或Context这类上下文参数来获取分组内的有序数据。少数数据库（如Snowflake）的UDF支持访问分组内行集，但属于特定数据库的扩展特性，并非通用SQL标准，兼容性较差，若使用这类数据库可参考官方文档实现。

内容的提问来源于stack exchange，提问作者Алексей