luxiaoxun/eagle

Real time data processing system based on flink and CEP

eagle

Real time data processing system based on flink and CEP(drools/siddhi)

中文详情：基于flink和drools的实时日志处理

Design:

Modules:

• eagle-api：基于springboot，提供策略规则的读写服务。
• eagle-common：通用类模块。
• eagle-alert：基于flink和siddhi的数据告警服务。
• eagle-log：基于flink和drools的日志处理服务。
• eagle-detection：基于flink的交易欺诈检测系统(fraud detection based on dynamic rules)。
  1. Flink 高级应用模式第一辑：欺诈检测系统案例研究
  2. Flink 高级应用模式第二辑：应用模式的动态更新
  3. Flink 中的应用部署（三）：自定义窗口处理

build

mvn clean package

debug mode:

"Run/Debug" => "Edit Configurations...",
"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