flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphTestUtils.java
/**
	 * Creates an execution graph containing the given vertices and the given restart strategy.
	 */
Creates an execution graph containing the given vertices and the given restart strategy.
Creates an execution graph containing the given vertices and the given restart strategy .
public static ExecutionGraph createSimpleTestGraph(
			JobID jid,
			TaskManagerGateway taskManagerGateway,
			RestartStrategy restartStrategy,
			JobVertex... vertices) throws Exception {
		int numSlotsNeeded = 0;
		for (JobVertex vertex : vertices) {
			numSlotsNeeded += vertex.getParallelism();
		}
		SlotProvider slotProvider = new SimpleSlotProvider(jid, numSlotsNeeded, taskManagerGateway);
		return createSimpleTestGraph(jid, slotProvider, restartStrategy, vertices);
	}
public static ExecutionGraph createSimpleTestGraph ( JobID jid , TaskManagerGateway taskManagerGateway , RestartStrategy restartStrategy , JobVertex ... vertices ) throws Exception { int numSlotsNeeded = 0 ; for ( JobVertex vertex : vertices ) { numSlotsNeeded += vertex . getParallelism ( ) ; } SlotProvider slotProvider = new SimpleSlotProvider ( jid , numSlotsNeeded , taskManagerGateway ) ; return createSimpleTestGraph ( jid , slotProvider , restartStrategy , vertices ) ; }
Creates an execution graph containing the given vertices and the given restart strategy.
Creates an execution graph containing the given vertices and the given restart strategy .