Interface MutableVertexAttemptNumberStore
-
- All Superinterfaces:
VertexAttemptNumberStore
- All Known Implementing Classes:
DefaultVertexAttemptNumberStore
public interface MutableVertexAttemptNumberStore extends VertexAttemptNumberStore
Mutability extension to theVertexAttemptNumberStore
.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
setAttemptCount(JobVertexID jobVertexId, int subtaskIndex, int attemptNumber)
Sets the attempt count for the given subtask of the given vertex.-
Methods inherited from interface org.apache.flink.runtime.executiongraph.VertexAttemptNumberStore
getAttemptCounts
-
-
-
-
Method Detail
-
setAttemptCount
void setAttemptCount(JobVertexID jobVertexId, int subtaskIndex, int attemptNumber)
Sets the attempt count for the given subtask of the given vertex.- Parameters:
jobVertexId
- vertex the subtask belongs tosubtaskIndex
- subtask to set the attempt number forattemptNumber
- attempt number to set
-
-