flink的JobGraph源码

Flink JobGraph的源码位于Flink的flink-core模块中，具体路径为：

flink-core/src/main/java/org/apache/flink/runtime/jobgraph/JobGraph.java

JobGraph类是Flink程序中Job Graph的主要数据结构，它包含了JobGraph的所有信息，例如Job ID、Job名称、任务并行度、算子、边等。此外，JobGraph还提供了一些方法用于操作Job Graph，例如添加算子、添加边、设置并行度等。

JobGraph的构造函数如下：

public JobGraph(String jobName, JobID jobId, List<JobVertex> vertices)

其中，jobName表示Job名称，jobId表示Job ID，vertices表示JobGraph中的所有算子和边。

JobGraph的主要方法包括：

- addVertex(JobVertex vertex)：添加一个算子到Job Graph中。
- connect(VertexID upStreamVertexId, VertexID downStreamVertexId)：添加一条边到Job Graph中。
- setParallelism(int parallelism)：设置Job的并行度。
- getVertices()：获取JobGraph中的所有算子和边。
- getJobID()：获取Job ID。

除此之外，JobGraph还有很多其他的方法，可以根据具体需求进行使用。