可以,定义清楚 getResultType 和 getParameterTypes, 可以参考[1]

[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/functions/udfs.html#implementation-guide


Dream-底限 <[email protected]> 于2020年7月21日周二 下午7:25写道:

> hi
>
> 我这面在定义一个表函数,通过继承TableFunction完成操作,但是eval方法中的参数类型都是java基本类型(至少看到的demo都是如此),想问一下eval方法中可以传flink
> 内部类型吗,比如说我想在eval()方法中传递Row类型要怎么操作,eval(Row row)
>

回复