使用Blink SQL+UDAF实现差值聚合计算

  1. 云栖社区>
  2. 博客>
  3. 正文

使用Blink SQL+UDAF实现差值聚合计算

纯庚 2019-07-31 13:49:19 浏览355
展开阅读全文

本案例根据某电网公司的真实业务需求,通过Blink SQL+UDAF实现实时流上的差值聚合计算,通过本案例,让读者熟悉UDAF编写,并理解UDAF中的方法调用关系和顺序。

感谢@军长在实现过程中的指导。笔者水平有限,若有纰漏,请批评指出。

一、客户需求

电网公司每天采集各个用户的电表数据(格式如下表),其中data_date为电表数据上报时间,cons_id为电表id,r1位电表度数,其他字段与计算逻辑无关,可忽略。为了后续演示方便,仅输入cons_id=100000002的数据。

no(string)

data_date(string)

cons_id(string)

org_no(string)

r1(double)

101

20190716

100000002

35401

13.76

101

20190717

100000002

35401

14.12

101

2

网友评论

登录后评论
0/500
评论
纯庚
+ 关注