Flink實時動態修改算子規則


  最近使用Flink實時告警項目,開始case by case硬編碼定義算子,進行實時計算告警是沒問題。但是業務場景結合規則引擎動態增刪改規則並實時生效計算並告警。Flink並不支持動態添加,修改算子計算規則,開始利用動態類加載機制勉強實現。但是對於Flink這套就不太優雅。下面來介紹下怎么利用Flink優雅實現動態增刪改算子規則。

     未完待續。。。


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM