天天看點

【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

繼續閱讀