1、数据来源
Flink CDC + Kafka?支持MySQL集群slave数据同步 或 jar包引入代码实现?
2、数据定义
元数据定义、表关系定义
3、数据存储
原始数据 HBase?结果数据 ElasticSearch?统计数据 MySQL?
4、数据转换
规则引擎?Flink?
5、数据服务
模型定义、OPEN API、统计报表、日志记录等
1、数据来源
Flink CDC + Kafka?支持MySQL集群slave数据同步 或 jar包引入代码实现?
2、数据定义
元数据定义、表关系定义
3、数据存储
原始数据 HBase?结果数据 ElasticSearch?统计数据 MySQL?
4、数据转换
规则引擎?Flink?
5、数据服务
模型定义、OPEN API、统计报表、日志记录等