Flink 流处理如何处理历史聚合？

wyyhbhjk 于 2023-08-01 发布在 Apache

关注(0)|答案(1)|浏览(125)

我有一个查询，用于汇总所有用户的历史成本，如

select uid, sum(payments) from tb

字符串
表tb包含2年的数据-假设如果现在运行该表，查询将计算2年的数据，而如果1年后运行该表，则查询将涉及3年的数据...
有没有可能把这个历史总结得行云流水？标准方法是什么？
此外...如果查询太复杂而无法重写，是否可以在此查询上应用流处理而没有任何“中间”结果？
提前感谢您的帮助。

1条答案

从Flink的Angular 来看，这个查询没有什么错。在流模式下，它将无限期地运行，并且只创建一个更新日志流作为输出。您可以在Flink的Dynamic Tables的Continuous Queries部分找到更多详细信息。