使用Blink CEP實現差值聚合計算

使用Blink SQL+UDAF實現差值聚合計算介紹瞭如何使用Blink SQL+UDAF實現實時流上的差值聚合計算，後來在與@付典就業務需求和具體實現方式進行探討時，付典提出通過CEP實現的思路和方法。 本文介紹通過CEP實現實時流上的差值聚合計算。 感謝@付典在實現過程中的指導。筆者水平有限，若有紕漏，請批評指出。 一、客戶需求 電網公司每天採集各個用戶的電錶數據（格式如下表），其中data_

>>阅读原文<<