You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by "casel.chen" <ca...@126.com> on 2023/05/26 07:43:44 UTC

用flink sql如何实现累计当天交易数量每来一笔交易都实时更新状态并输出到下游?

用flink sql如何实现累计当天交易数量每来一笔交易都实时更新状态并输出到下游?

Re: 用flink sql如何实现累计当天交易数量每来一笔交易都实时更新状态并输出到下游?

Posted by Shammon FY <zj...@gmail.com>.

Hi

可以将天级时间和其他需要聚合的字段组成key，使用聚合算子，默认会每条数据完成计算后实时输出结果

Best,
Shammon FY

On Fri, May 26, 2023 at 3:44 PM casel.chen <ca...@126.com> wrote:

> 用flink sql如何实现累计当天交易数量每来一笔交易都实时更新状态并输出到下游?