class DefaultLogicalVertex implements LogicalVertex<DefaultLogicalVertex, DefaultLogicalResult> {

	@Override
	public Iterable<DefaultLogicalResult> getConsumedResults() {
		return jobVertex.getInputs().stream()
			.map(JobEdge::getSource)
			.map(IntermediateDataSet::getId)
			.map(resultRetriever)
			.collect(Collectors.toList());
	}

	  DefaultLogicalVertex(
			final JobVertex jobVertex,
			final Function<IntermediateDataSetID, DefaultLogicalResult> resultRetriever);

}