Alink单表操作和UDF操作

Alink 支持 Flink sql操作, SQL 语句中对数据的操作都是通过表名进行的,要对某个Alink 批式组件 BatchOperator 输出的 Table 类型数据进行操作,需要先为其注册一个名称。下面内容包括 1. 内置函数介绍; 2. 单表操作和多表Join操作;2. 用户定义函数(UDFUDTF )

image-20230117153727256

image-20230117161259513

我们还可以在sqlQuery() 中使用UDF,相关代码如下,得到的结果和使用UDFBatchOp 组件得到的结果一致。需要注意的是,使用SQL语句前,要先注册数据表ratings .