Flink 内置函数的有一些是直接 codegen 出来的，有一些是调用的 util。 对于前者，得去看org.apache.flink.table.planner.codegen.calls.ScalarOperatorGens。 对于后者，可以看下 org.apache.flink.table.planner.codegen.calls.BuiltInMethods.
Best, Jark On Wed, 12 Aug 2020 at 10:39, shizk233 <wangwangdaxian...@gmail.com> wrote: > hi all, > > 请教一下，flink sql内置的众多functions[1]有对应的Java实现类吗？我只在blink table > planner模块下的functions package里找到了一部分，并且是基于Expresstion的。 > > 问题来源：我试图在flink > sql里去做debug，如果是自定义的udf可以打断点在实现上，但内置函数没找到相应的实现，似乎也没有相应的文档在这一块。 > > [1] > > https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/functions/systemFunctions.html >
