Flink-Table SQL 实践编程 StreamTableEnvironment(十)下

StreamTableEnvironment主要是流式数据处理,本文主要实现GroupBy Window Aggregation、Over Window aggregation对应sql api的代码实现,同时实现流数据表join 链接。java 代码中使用socket方式做为source数据输入方式,闲话不说,具体代码以下:sql 1、依赖的实体类以及ScalarFunction信息:apach
相关文章
相关标签/搜索