Apache Flink 1.10中定义 Python UDF的方式有哪些？

在 Apache Flink 1.10 中我们有多种方式进行 UDF 的定义，比如： ● Extend ScalarFunction, e.g

class HashCodeMean(ScalarFunction):
 def eval(self, i, j):
 return (hash(i) + hash(j)) / 2

● Lambda Functio

lambda i, j: (hash(i) + hash(j)) / 2

● Named Function

def hash_code_mean(i, j):
 return (hash(i) + hash(j)) / 2

● Callable Function

class CallableHashCodeMean(object):
 def __call__(self, i, j):
 return (hash(i) + hash(j)) / 2

上面定义函数除了第一个扩展 ScalaFunction 的方式是 PyFlink 特有 的，其他方式都是 Python 语言本身就支持的，也就是说，在 Apache Flink 1.10 中 PyFlink 允许以任何 Python 语言所支持的方式定义 UDF。