org.apache.flink.runtime.executiongraph

Class ExecutionGraphBuilder

java.lang.Object

org.apache.flink.runtime.executiongraph.ExecutionGraphBuilder

public class ExecutionGraphBuilder
extends Object

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

Method Summary

Modifier and Type	Method and Description
static ExecutionGraph	buildGraph(ExecutionGraph prior, JobGraph jobGraph, Configuration jobManagerConfig, ScheduledExecutorService futureExecutor, Executor ioExecutor, SlotProvider slotProvider, ClassLoader classLoader, CheckpointRecoveryFactory recoveryFactory, Time rpcTimeout, RestartStrategy restartStrategy, MetricGroup metrics, BlobWriter blobWriter, Time allocationTimeout, org.slf4j.Logger log, ShuffleMaster<?> shuffleMaster, JobMasterPartitionTracker partitionTracker) Builds the ExecutionGraph from the JobGraph.
static ExecutionGraph	buildGraph(ExecutionGraph prior, JobGraph jobGraph, Configuration jobManagerConfig, ScheduledExecutorService futureExecutor, Executor ioExecutor, SlotProvider slotProvider, ClassLoader classLoader, CheckpointRecoveryFactory recoveryFactory, Time rpcTimeout, RestartStrategy restartStrategy, MetricGroup metrics, BlobWriter blobWriter, Time allocationTimeout, org.slf4j.Logger log, ShuffleMaster<?> shuffleMaster, JobMasterPartitionTracker partitionTracker, FailoverStrategy.Factory failoverStrategyFactory)

Methods inherited from class java.lang.Object

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

Method Detail

buildGraph

public static ExecutionGraph buildGraph(@Nullable
                                        ExecutionGraph prior,
                                        JobGraph jobGraph,
                                        Configuration jobManagerConfig,
                                        ScheduledExecutorService futureExecutor,
                                        Executor ioExecutor,
                                        SlotProvider slotProvider,
                                        ClassLoader classLoader,
                                        CheckpointRecoveryFactory recoveryFactory,
                                        Time rpcTimeout,
                                        RestartStrategy restartStrategy,
                                        MetricGroup metrics,
                                        BlobWriter blobWriter,
                                        Time allocationTimeout,
                                        org.slf4j.Logger log,
                                        ShuffleMaster<?> shuffleMaster,
                                        JobMasterPartitionTracker partitionTracker)
                                 throws JobExecutionException,
                                        JobException

Builds the ExecutionGraph from the JobGraph. If a prior execution graph exists, the JobGraph will be attached. If no prior execution graph exists, then the JobGraph will become attach to a new empty execution graph.

Throws:

JobExecutionException

JobException

buildGraph

public static ExecutionGraph buildGraph(@Nullable
                                        ExecutionGraph prior,
                                        JobGraph jobGraph,
                                        Configuration jobManagerConfig,
                                        ScheduledExecutorService futureExecutor,
                                        Executor ioExecutor,
                                        SlotProvider slotProvider,
                                        ClassLoader classLoader,
                                        CheckpointRecoveryFactory recoveryFactory,
                                        Time rpcTimeout,
                                        RestartStrategy restartStrategy,
                                        MetricGroup metrics,
                                        BlobWriter blobWriter,
                                        Time allocationTimeout,
                                        org.slf4j.Logger log,
                                        ShuffleMaster<?> shuffleMaster,
                                        JobMasterPartitionTracker partitionTracker,
                                        FailoverStrategy.Factory failoverStrategyFactory)
                                 throws JobExecutionException,
                                        JobException

Throws:

JobExecutionException

JobException