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




































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









