阿里云flink操作示例

发布时间 2023-07-21 18:14:02作者: 梦呓空间

前期简单查询:(不同版本语法或有不同,当前版本:专有云flink1.11)

1、可以先简单定义自己的源表字段(下图test),进行简单查询,确定结果是否输出(结果输出是一直存在的,源表实时新增一条数据,查询结果就会新增一条数据)

备注:以下示例特殊信息写成自己的信息;可定义多个源表

2、定义结果表(l_result)

 3、查询sql编写(可以定义视图t_view、也可以直接进行select查询)

 4、写入sink结果表