数据交换平台

API接口

文件数据源（FTP等） 

API数据源（已配置在数据源管理中）

UFX接口

数据源管理

提交flinkx脚本

finkx任务

flink集群

flinkx任务的目标数据源

消息中间件支持 （CDC转Kafka消息(JSON格式)、文件数据转kafka）

消息中间件支持 (kafka等)

配置管理(包含上游数据来源的配置，和下游数据去向的配置，校验和转换规则的配置)

数据来源

数据转换规则配置

数据去向

finkx任务管理（需要配置一个数据来源和目标数据源，进行数据转换）

实时网关处理

通过数据源管理的可视化页面添加到数据源管理中

任务执行器（flinkx脚本提交的方式）

数据库/NoSQL （mysql、oracle、 redis） 

监控中心

数据库/NoSQL （mysql、oracle、 redis）

调度中心(已有功能)

运行

作为flinkx任务的数据来源

数据处理

数据校验规则配置