本篇基于Flink-Cep 来实现规则动态变更加载，同时参考了Flink中文社区刘博老师的分享，在这个分享里面是针对在处理流中每一个Key使用不同的规则，本篇的讲解将不区分key的规则。
技术背景简介 Flink-Cep 是flink中的高级library，用于进行复杂事件处理，例如某一类事件连续出现三次就触发告警，可以类比Siddhi、Esper； Groovy 是一种动态脚本语言，可以让用户输入代码变成后台可执行代码...案例分析 物联网通常都是设备数据，比喻说设备的温度、耗电量等等，会有对设备的监控，例如求设备连续三个点的值大于10且三个点的求和值大于100，要求将这三个点发送到下游进行处理，首先看一下直接使用Flink-Cep...总结 本篇以一个简单的demo来介绍Flink-cep+Groovy+Aviator的实现流程，为后续介绍Flink-Cep如何实现动态规则变更打下基础，尽情期待。。。
SKIPPED [INFO] flink-cep .............................................SUCCESS [ 0.071 s] [INFO] flink-cep ..........................................
SUCCESS [ 0.100 s] [INFO] flink-cep ..........................................
SUCCESS [ 0.058 s][INFO] flink-cep ..........................................
SUCCESS [ 0.018 s] [INFO] flink-cep ..........................................
Java org.apache.flink flink-cep
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
