Apache Flink 1.10中使用 Python UDF的方式有几种以及正确使用方式是什么？

定义完 UDF 我们应该怎样使用呢？ Apache Flink 1.10 中提供了 2 种 Decorators，如下： ● Decorators - udf(), e.g. :

udf(lambda i, j: (hash(i) + hash(j)) / 2,
 [for input types], [for result types])

Decorators - @udf, e.g. :
@udf(input_types=..., result_type=...)
 def hash_code_mean(…):
 return …

然后在使用之前进行注册，如下： st_env.register_function("hash_code", hash_code_mean) 接下来就可以在 Table API/SQL 中进行使用了，如下：

my_table.select("hash_code_mean(a, b)").insert_into("Results")