前面讲了 Flink SQL 的 TableEnvironment、Table API、查询与过滤、分组与聚合、自定义 UDF,这些都是无状态或有状态的基础操作。但流处理有一个核心问题:无界流上的聚合