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