Real time data processing system based on flink and CEP(drools/siddhi)
- eagle-api：基于springboot，提供策略规则的读写服务。
- eagle-common：通用类模块。
- eagle-alert：基于flink和siddhi的数据告警服务。
- eagle-log：基于flink和drools的日志处理服务。
- eagle-detection：基于flink的交易欺诈检测系统(Dynamic CEP)。
build
mvn clean package
IDE dev mode:
"Run/Debug" => "Edit Configurations...",
"Program Arguments" => "--mode dev"
"Build and run" section select "Modify options" => Java => Add dependencies with "Provided" scope to classpath.
cluster mode:
flink run -m yarn-cluster -ynm eagle-log -j eagle-log.jar -c com.alarm.eagle.EagleLogApp -arg "--mode test"
eagle-api
http://localhost:8080/eagle-api/swagger-ui/index.html