@Test(expected = IllegalArgumentException.class) public void finishingUnknownVertexThrowsException() { final PipelinedRegion from = PipelinedRegion.from(TEST_EXECUTION_VERTEX_ID); final PipelinedRegionExecutionView pipelinedRegionExecutionView = new PipelinedRegionExecutionView(from); final ExecutionVertexID unknownVertexId = new ExecutionVertexID(new JobVertexID(), 0); pipelinedRegionExecutionView.vertexFinished(unknownVertexId); }
public void vertexFinished(final ExecutionVertexID executionVertexId) { checkArgument(pipelinedRegion.contains(executionVertexId)); unfinishedVertices.remove(executionVertexId); }
PipelinedRegionExecutionView { public void vertexFinished(final ExecutionVertexID executionVertexId) { checkArgument(pipelinedRegion.contains(executionVertexId)); unfinishedVertices.remove(executionVertexId); } }
PipelinedRegionExecutionView { public void vertexFinished(final ExecutionVertexID executionVertexId) { checkArgument(pipelinedRegion.contains(executionVertexId)); unfinishedVertices.remove(executionVertexId); } PipelinedRegionExecutionView(final PipelinedRegion pipelinedRegion); }
PipelinedRegionExecutionView { public void vertexFinished(final ExecutionVertexID executionVertexId) { checkArgument(pipelinedRegion.contains(executionVertexId)); unfinishedVertices.remove(executionVertexId); } PipelinedRegionExecutionView(final PipelinedRegion pipelinedRegion); boolean isFinished(); void vertexFinished(final ExecutionVertexID executionVertexId); void vertexUnfinished(final ExecutionVertexID executionVertexId); PipelinedRegion getPipelinedRegion(); }
PipelinedRegionExecutionView { public void vertexFinished(final ExecutionVertexID executionVertexId) { checkArgument(pipelinedRegion.contains(executionVertexId)); unfinishedVertices.remove(executionVertexId); } PipelinedRegionExecutionView(final PipelinedRegion pipelinedRegion); boolean isFinished(); void vertexFinished(final ExecutionVertexID executionVertexId); void vertexUnfinished(final ExecutionVertexID executionVertexId); PipelinedRegion getPipelinedRegion();  }