public class VertexFinishedStateChecker extends Object
As a whole, it ensures
Constructor and Description |
---|
VertexFinishedStateChecker(Set<ExecutionJobVertex> vertices,
Map<OperatorID,OperatorState> operatorStates) |
Modifier and Type | Method and Description |
---|---|
void |
validateOperatorsFinishedState() |
public VertexFinishedStateChecker(Set<ExecutionJobVertex> vertices, Map<OperatorID,OperatorState> operatorStates)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.