flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionJobVertex.java
/**
	 * Schedules all execution vertices of this ExecutionJobVertex.
	 *
	 * @param slotProvider to allocate the slots from
	 * @param queued if the allocations can be queued
	 * @param locationPreferenceConstraint constraint for the location preferences
	 */
Schedules all execution vertices of this ExecutionJobVertex.
@param slotProvider to allocate the slots from
@param queued if the allocations can be queued
@param locationPreferenceConstraint constraint for the location preferences
Schedules all execution vertices of this ExecutionJobVertex . @param slotProvider to allocate the slots from @param queued if the allocations can be queued @param locationPreferenceConstraint constraint for the location preferences
public void scheduleAll(
			SlotProvider slotProvider,
			boolean queued,
			LocationPreferenceConstraint locationPreferenceConstraint) {
		final ExecutionVertex[] vertices = this.taskVertices;
		for (ExecutionVertex ev : vertices) {
			ev.scheduleForExecution(slotProvider, queued, locationPreferenceConstraint);
		}
	}
public void scheduleAll ( SlotProvider slotProvider , boolean queued , LocationPreferenceConstraint locationPreferenceConstraint ) { final ExecutionVertex [ ] vertices = this . taskVertices ; for ( ExecutionVertex ev : vertices ) { ev . scheduleForExecution ( slotProvider , queued , locationPreferenceConstraint ) ; } }
Schedules all execution vertices of this ExecutionJobVertex.
Schedules all execution vertices of this ExecutionJobVertex .
// kick off the tasks