Package | Description |
---|---|
org.apache.flink.runtime.executiongraph |
Modifier and Type | Class and Description |
---|---|
class |
DefaultSubtaskAttemptNumberStore
Simple container for subtask attempt counts backed by a list.
|
Modifier and Type | Method and Description |
---|---|
SubtaskAttemptNumberStore |
DefaultVertexAttemptNumberStore.getAttemptCounts(JobVertexID vertexId) |
SubtaskAttemptNumberStore |
VertexAttemptNumberStore.getAttemptCounts(JobVertexID vertexId)
Returns the attempt numbers for the given vertex.
|
Modifier and Type | Method and Description |
---|---|
protected void |
ExecutionJobVertex.initialize(int executionHistorySizeLimit,
Time timeout,
long createTimestamp,
SubtaskAttemptNumberStore initialAttemptCounts) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.