详解 Flink Table API 和 Flink SQL 之表操作
一、表环境配置 /**表环境的主要功能:1.注册 Catalog 和表2.执行 SQL 查询3.注册用户自定义函数(UDF)4.DataStream 和表之间的转换 */ public class TestTableEnvironment {public static void main(String[] args) throws Exception {//1.配…
2025-01-09