实时计算框架分成四层: 1. Function 层:实现比如 Json 解析、RPC 调用、以及数据流的链接;2. Process 层:对 Flink 引擎、Data Stream、Data Set、SQL 等 API 进行封装;3. Function 和 Process 组合生成 Operator,对具体的处理逻辑进行封装,比如实现 Source、Sink、Filter、Join 等常用的算子;4. 一个或者多个 Operator 构成不同的场景,比如多流拼接导数的 Top N、动线分析,这些构成了 JSON 的配置文件,然后再通过通用的引擎解析配置文件提交任务。