code: public void deployAssignedPipeline(final ExecutionPipeline pipeline) {
  
  		final JobID jobID = null;
  
  		final Map<AbstractInstance, List<ExecutionVertex>> verticesToBeDeployed = new HashMap<AbstractInstance, List<ExecutionVertex>>();
  		final Set<ExecutionVertex> alreadyVisited = new HashSet<ExecutionVertex>();
  
  		final Iterator<ExecutionVertex> it = pipeline.iterator();
  		while (it.hasNext()) {
  			findVerticesToBeDeployed(it.next(), verticesToBeDeployed, alreadyVisited);
  		}
  
  		if (!verticesToBeDeployed.isEmpty()) {
  
  			final Iterator<Map.Entry<AbstractInstance, List<ExecutionVertex>>> it2 = verticesToBeDeployed
  				.entrySet()
  				.iterator();
  
  			while (it2.hasNext()) {
  
  				final Map.Entry<AbstractInstance, List<ExecutionVertex>> entry = it2.next();
  				this.deploymentManager.deploy(jobID, entry.getKey(), entry.getValue());
  			}
  		}
  	}
docs: Collects all execution vertices with the state ASSIGNED from the given pipeline and deploys them on the assigned
  {@link AllocatedResource} objects.
  
  @param pipeline
  the execution pipeline to be deployed