Package org.apache.flink.runtime.executiongraph

Class DefaultExecutionGraphBuilder

java.lang.Object

org.apache.flink.runtime.executiongraph.DefaultExecutionGraphBuilder

public class DefaultExecutionGraphBuilder
extends Object

Utility class to encapsulate the logic of building an DefaultExecutionGraph from a JobGraph.

Method Summary

Modifier and Type	Method	Description
static DefaultExecutionGraph	buildGraph(JobGraph jobGraph, Configuration jobManagerConfig, ScheduledExecutorService futureExecutor, Executor ioExecutor, ClassLoader classLoader, CompletedCheckpointStore completedCheckpointStore, CheckpointsCleaner checkpointsCleaner, CheckpointIDCounter checkpointIdCounter, Duration rpcTimeout, BlobWriter blobWriter, org.slf4j.Logger log, ShuffleMaster<?> shuffleMaster, JobMasterPartitionTracker partitionTracker, TaskDeploymentDescriptorFactory.PartitionLocationConstraint partitionLocationConstraint, ExecutionDeploymentListener executionDeploymentListener, ExecutionStateUpdateListener executionStateUpdateListener, long initializationTimestamp, VertexAttemptNumberStore vertexAttemptNumberStore, VertexParallelismStore vertexParallelismStore, CheckpointStatsTracker checkpointStatsTracker, boolean isDynamicGraph, ExecutionJobVertex.Factory executionJobVertexFactory, MarkPartitionFinishedStrategy markPartitionFinishedStrategy, boolean nonFinishedHybridPartitionShouldBeUnknown, JobManagerJobMetricGroup jobManagerJobMetricGroup)
static boolean	isCheckpointingEnabled(JobGraph jobGraph)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

buildGraph

public static DefaultExecutionGraph buildGraph(JobGraph jobGraph,
                                               Configuration jobManagerConfig,
                                               ScheduledExecutorService futureExecutor,
                                               Executor ioExecutor,
                                               ClassLoader classLoader,
                                               CompletedCheckpointStore completedCheckpointStore,
                                               CheckpointsCleaner checkpointsCleaner,
                                               CheckpointIDCounter checkpointIdCounter,
                                               Duration rpcTimeout,
                                               BlobWriter blobWriter,
                                               org.slf4j.Logger log,
                                               ShuffleMaster<?> shuffleMaster,
                                               JobMasterPartitionTracker partitionTracker,
                                               TaskDeploymentDescriptorFactory.PartitionLocationConstraint partitionLocationConstraint,
                                               ExecutionDeploymentListener executionDeploymentListener,
                                               ExecutionStateUpdateListener executionStateUpdateListener,
                                               long initializationTimestamp,
                                               VertexAttemptNumberStore vertexAttemptNumberStore,
                                               VertexParallelismStore vertexParallelismStore,
                                               CheckpointStatsTracker checkpointStatsTracker,
                                               boolean isDynamicGraph,
                                               ExecutionJobVertex.Factory executionJobVertexFactory,
                                               MarkPartitionFinishedStrategy markPartitionFinishedStrategy,
                                               boolean nonFinishedHybridPartitionShouldBeUnknown,
                                               JobManagerJobMetricGroup jobManagerJobMetricGroup)
                                        throws JobExecutionException,
                                               JobException

Throws:

JobExecutionException

JobException

isCheckpointingEnabled

public static boolean isCheckpointingEnabled(JobGraph jobGraph)