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

本案例根据某电网公司的真实业务需求，经过Blink SQL+UDAF实现实时流上的差值聚合计算，经过本案例，让读者熟悉UDAF编写，并理解UDAF中的方法调用关系和顺序。 感谢@军长在实现过程当中的指导。笔者水平有限，如有纰漏，请批评指出。 html 1、客户需求 电网公司天天采集各个用户的电表数据（格式以下表），其中data_date为电表数据上报时间，cons_id为电表id，r1为电表度数，

>>阅读原文<<