flinksql中,update/delete流不支持max over开窗
时间: 2023-12-06 13:39:58 浏览: 75
【数据库作业9】SQL练习6 – INSERT / UPDATE / DELETE / NULL / VIEW
5星 · 资源好评率100%
是的,Flink SQL 中的 UPDATE 和 DELETE 操作不支持使用 MAX OVER 开窗函数。这是因为 UPDATE 和 DELETE 操作需要在数据流中对特定行进行修改或删除,而 MAX OVER 开窗函数需要对整个窗口的数据进行聚合计算,这两者的计算方式不同,不能直接结合使用。如果需要对数据流进行实时聚合计算并支持 UPDATE 和 DELETE 操作,可以考虑使用 Flink 的 Table API 或 DataStream API 以编程方式实现。
阅读全文