@Override
    public Iterable<DefaultLogicalResult> getProducedResults() {
        return jobVertex.getProducedDataSets().stream()
                .map(IntermediateDataSet::getId)
                .map(resultRetriever)
                .collect(Collectors.toList());
    }
@Test
    public void testGetProducedResults() {
        assertResultsEquals(results, upstreamLogicalVertex.getProducedResults());
    }