如何为 Presto 编写自定义窗口函数?

问题描述

我想创建一个自定义 Window 函数,该函数处理已排序的双精度流并为每个分区生成单个输出双精度。必须对值进行排序。 Window 函数可以一次处理单行(无需向后/向前看),只要它可以保持每个分区的内部状态即可。

签名看起来像这样:

SELECT my_windows_func() OVER (PARTITION BY my_key ORDER BY my_val ASC) AS my_stuff

现在,我想出了如何创建 AggreagtionFunctions、ScalarFunctions,但使用 WindowFunctions 我不知道从哪里开始,也找不到任何在线文档。

我应该为我的用例实现哪个接口?我可以强制用户在调用时添加 ORDER BY 子句吗?我可以参考任何示例代码吗?

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)