首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
MCP广场
社区首页 >问答首页 >如何基于批处理表的增量窗口为计算编写SQL

如何基于批处理表的增量窗口为计算编写SQL
EN

Stack Overflow用户
提问于 2018-03-26 02:32:11
回答 1查看 85关注 0票数 0

我的要求是基于批处理表的增量大小窗口进行计算。

例如,第一个窗口有1行,第二个窗口有2行(包括第1窗口的1行和新的行),然后第3窗口中的3行(包括第2窗口的2行和新的行)等等。

例如:

来源表:

日期时间/ productId价格

3-1,p1,10,000,000

3-2,p1,20,000

3-3 p1 \x{e76f} 30

3-4,p1,40,000,000

成果表:

日期-时间- productId -平均

3-1维p1 \ 10/1 \x{e76f}

3-2 \x{e76f} p1 \x{e76f} (10+20)/2

3-3 \x{e76f} p1 \x{e76f} (10+20+30)/3

3-4 \x{e76f} p1 \x{e76f} (10+20+30+40)/4

我试图找到一种用Sql实现这一需求的方法,在我看来,OVER可以做到这一点,但还没有在flink中实现,所以我需要另一种方法。

BTW:

I尝试使用1天的滚动窗口,并将先前的值存储在用户定义的聚合对象中,但是失败了,因为聚合对象将被所有产品重用,而不是每个产品的单个对象。

EN

回答 1

Stack Overflow用户

回答已采纳

发布于 2018-03-26 11:27:16

Flink的SQL还不支持批处理表上的OVER子句。您可以跟踪此工作的状态,这里

但是,您是否考虑在流表上实现此行为?流表也可以从静态文件(如CSV文件)中读取,而且还支持许多操作。不过,这取决于您希望在查询中使用的其他操作。

票数 1
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/49483136

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档