数据萃取标签计算系统

技术架构：Flink、Hbase、Kafka、ZooKeeper、QLexpress、Redis、MySql 等。
项目描述：充分利用大数据技术实现事件精准分析、实时计算、快速派遣，平台针对事件信息进行实时动态生产事件
标签及事件关联对象的标签，通过生成的标签数据对事件及事件所对象进行数据展示和分析，快速决策。
职责描述：
基于 Kafka 实现数据集及数据对象分类存储，分类消费数据计算。
基于责任链模式实现平台统一业务过规则滤器设计，基于 Flink 实时性实现，基础标签和各种规则标签生产。
基于 Flink CEP 特性，实现事件各种超时处置及复杂办理标签计算功能。
基于 Hbase 特性高可用、高性能和可伸缩性、非结构化数据库，将计算完成标签持久化到 Hbase 中。