【flink】sql 非窗口聚合-实践
发布时间
阅读量：
阅读量
在计算今日当前时间的交易总额GVM时，存在两种不同的实现方式：
第一种方式无法接入kafka（适用于flink版本1.12之前的版本）
第二种方式则支持接入kafka
-- 这样的sql是每来一条输出一次，形成的是回撤流，不断更新的
select
max(ts) as ts,
sum(money) as gvm
from jiaoyi group by dt;
-- order 必须带有时间属性的字段，这样的sql形成的是append stream
select
ts,
sum(money) over w as gvm
from jiaoyi group by dt
window w as (partition by dt order by et rows between unbounded proceding and current row);
若希望避免每次仅输出一条信息，应如何处理？
-- 对于这种全部评论 (0)
还没有任何评论哟~