使用Blink CEP实现差值聚合计算

使用Blink SQL+UDAF实现差值聚合计算介绍了如何使用Blink SQL+UDAF实现实时流上的差值聚合计算，后来在与@付典就业务需求和具体实现方式进行探讨时，付典提出通过CEP实现的思路和方法。 本文介绍通过CEP实现实时流上的差值聚合计算。 感谢@付典在实现过程中的指导。笔者水平有限，若有纰漏，请批评指出。 一、客户需求 电网公司每天采集各个用户的电表数据（格式如下表），其中data_

>>阅读原文<<