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

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

>>阅读原文<<