使用Blink SQL+UDAF實現差值聚合計算

本案例根據某電網公司的真實業務需求，經過Blink SQL+UDAF實現實時流上的差值聚合計算，經過本案例，讓讀者熟悉UDAF編寫，並理解UDAF中的方法調用關係和順序。 感謝@軍長在實現過程當中的指導。筆者水平有限，如有紕漏，請批評指出。 html 1、客戶需求 電網公司天天採集各個用戶的電錶數據（格式以下表），其中data_date爲電錶數據上報時間，cons_id爲電錶id，r1爲電錶度數，

>>阅读原文<<