flink中级篇-DAG图的剖析

一.DAG图的整体架构:   Flink框架引擎把执行计划抽象为四个层次的数据结构,分别是API层、静态topology、JobGraph、ExecutionGraph等。node 具体的结构入下图:web 二. 流做业DAG图分析 API层     用户经过StreamApI或是BatchAPI描述Job的逻辑,并经过调用链把做业逻辑操做串联起来,对于用户而言,业务抽象的是一个一个的有特定功能的
相关文章
相关标签/搜索