天天看点

【Flink】Flink PipelineExecutor 体系1.概述2.AbstractJobClusterExecutor

文章目录

  • 1.概述
  • 2.AbstractJobClusterExecutor
  • 3.YarnJobClusterExecutor
【Flink】Flink PipelineExecutor 体系1.概述2.AbstractJobClusterExecutor

1.概述

PipelineExecutor负责执行一个{@link Pipeline}的实体,即一个用户作业。

其继承体系如下

【Flink】Flink PipelineExecutor 体系1.概述2.AbstractJobClusterExecutor

2.AbstractJobClusterExecutor

继续阅读