大数据Flink(一百零一):SQL 表值函数(Table Function)-LMLPHP

文章目录

SQL 表值函数(Table Function)


SQL 表值函数(Table Function)

Python UDTF,即 Python TableFunction,针对每一条输入数据,Python UDTF 可以产生 0 条、1 条或者多条输出数据,此外,一条输出数据可以包含多个列。比如以下示例,定义了一个名字为 split 的Python UDF,以指定字符串为分隔符,将输入字符串切分成两个字符串:

from pyflink.table.udf import udtf
from pyflink.table import DataTypes

@udtf(result_types
10-24 21:27