class PipelinedRegionSchedulingStrategy implements SchedulingStrategy {

	@Override
	public void startScheduling() {
		final Set<SchedulingPipelinedRegion> sourceRegions = IterableUtils
			.toStream(schedulingTopology.getAllPipelinedRegions())
			.filter(region -> !region.getConsumedResults().iterator().hasNext())
			.collect(Collectors.toSet());
		maybeScheduleRegions(sourceRegions);
	}

	public  PipelinedRegionSchedulingStrategy(
			final SchedulerOperations schedulerOperations,
			final SchedulingTopology schedulingTopology);

}