class DefaultSchedulingPipelinedRegion implements SchedulingPipelinedRegion {

	@Override
	public DefaultExecutionVertex getVertex(final ExecutionVertexID vertexId) {
		final DefaultExecutionVertex executionVertex = executionVertices.get(vertexId);
		if (executionVertex == null) {
			throw new IllegalArgumentException(String.format(
				"Execution vertex %s not found in pipelined region",
				vertexId));
		}
		return executionVertex;
	}

	public  DefaultSchedulingPipelinedRegion(Set<DefaultExecutionVertex> defaultExecutionVertices);

}