自定义 UDAF 不起作用（Ksql：Confluent）答案

【问题标题】：Custom UDAF not working ( Ksql: Confluent)自定义 UDAF 不起作用（Ksql：Confluent）
【发布时间】：2018-05-23 07:11:37
【问题描述】：

我在 Ksql 中创建自定义 UDAF 时遇到问题。用例是在翻滚窗口中查找列的“第一个”和“最后一个”值。 UDAF (https://docs.confluent.io/current/ksql/docs/syntax-reference.html#aggregate-functions) 中没有这样的内置功能，因此我正在尝试创建自定义 UDAF。

我。创建了 UDAF & AggregateFunctionFactory 并在 FunctionRegistry 中注册如下：

addAggregateFunctionFactory(new MyAggFunctionFactory());

ii.Build ksql-engine jar 并在以下路径 $CONFLUENT_HOME/share/java/ksql 的 confluent 包中替换它。

iii.重启ksql-server

但是，该功能似乎未注册。有什么建议吗？

融合版本：4.1.0

注意：我尝试创建简单的 UDF 。效果很好。问题在于 UDAF

【问题讨论】：

【解决方案1】：

问题是我将函数命名为“First”，这似乎是一些关键字。改了函数名，成功了

【讨论】：

很高兴它的工作！如果这是由 First 作为保留字的某些问题引起的，我建议针对 KSQL 提出一个 Github 问题来解决这个问题，这样如果其他人遇到同样的事情，你就会得到更好的错误消息。