@Override
    public DefaultLogicalVertex getProducer() {
        return vertexRetriever.apply(intermediateDataSet.getProducer().getID());
    }
@Test
    public void testGetProducer() {
        assertVertexInfoEquals(producerVertex, logicalResult.getProducer());
    }