功能描述: 使用CEP作为复杂事件处理引擎时,当逻辑频繁发生修改,以及阈值频繁调整时
          整个程序需要停止后,修改代码,重新打包程序然后给集群提交，无法实现逻辑
          动态修改和外部动态注入,目前已经实现了CEP逻辑动态注入，基于消息驱动逻
          辑修改，可以手动往source端注入特定消息实现细腻度控制逻辑注入感知     

    Boolean needChange()      每条数据会调用这个方法，用于确定这条数据是否会触发规则更新
    Pattern returnPattern()   触发更新时调用，用于返回新的pattern作为新规则

mvn clean install -Dmaven.test.skip=true

org.apache.flink.streaming.examples.cep.Driver

Contributors

Stargazers

Forkers

codeamateur jiemotongxue kevinshang ty20130216 zhanjians baosince liushui112011 jaslou dengyu123 leizeonban f756692193 williamsong112 xiejiajun ahuachen benhe119 imperio-wxm ambition119 bradley-db huaxuehuaxue chrisliu007 startime-h sing173 victoryxs dizhaung yongmeibian bg1011 sqw1008 leon0401 zxf1864 daniel-yee towwb zhaohaolin lxp4352 lwk123 lizhitao0923 ghfork brijeshsmita fangzhimeng linhtao betacat01 cjjxfli mt0803 freebird2014 liuzidi bigdata0803 242560589 sukura-tong imuchen