热门标签
更多>
搜索结果
查询Tags标签: JobGraph,共有 3条记录-
Flink到底是怎么把你的程序抽象的?
导读: 大家好我是胖子,我想我们大家都知道Flink是有状态的实时计算引擎,很多人不理解一个计算引擎应该怎么做呢,其实这就涉及到了Flink的核心,也就是它的应用程序抽象,我们都知道Flink会将我们编写的程序来进行转换成一个图,接着会进行优化,以及转换成一些可执行的…
2022/3/20 20:28:30 人评论 次浏览 -
Flink源码解读(二):JobGraph源码解读
目录 JobGraph源码解读 JobGraph生成过程 入口函数 createJobGraph函数 参考JobGraph源码解读 上回说到,StreamGraph的源码其中是在客户端生成,并且是生成Node节点和Edge,主要是通过StreamAPI生成,表示拓扑结构,这次给大家讲讲JobGraph的生成(以Yarn集群模式)。 首先…
2021/10/7 11:12:52 人评论 次浏览 -
Flink源码解读(二):JobGraph源码解读
目录 JobGraph源码解读 JobGraph生成过程 入口函数 createJobGraph函数 参考JobGraph源码解读 上回说到,StreamGraph的源码其中是在客户端生成,并且是生成Node节点和Edge,主要是通过StreamAPI生成,表示拓扑结构,这次给大家讲讲JobGraph的生成(以Yarn集群模式)。 首先…
2021/10/7 11:12:52 人评论 次浏览