Package | Description |
---|---|
org.apache.flink.runtime.checkpoint | |
org.apache.flink.runtime.deployment | |
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.scheduler |
Modifier and Type | Method and Description |
---|---|
Optional<ExecutionVertex> |
ExecutionAttemptMappingProvider.getVertex(ExecutionAttemptID id) |
Modifier and Type | Method and Description |
---|---|
void |
CheckpointStatsTracker.reportIncompleteStats(long checkpointId,
ExecutionVertex vertex,
CheckpointMetrics metrics) |
Constructor and Description |
---|
ExecutionAttemptMappingProvider(Iterable<ExecutionVertex> tasksIterable) |
Modifier and Type | Method and Description |
---|---|
static TaskDeploymentDescriptorFactory |
TaskDeploymentDescriptorFactory.fromExecutionVertex(ExecutionVertex executionVertex,
int attemptNumber) |
Modifier and Type | Method and Description |
---|---|
ExecutionVertex |
DefaultExecutionGraph.getExecutionVertexOrThrow(ExecutionVertexID id) |
ExecutionVertex |
InternalExecutionGraphAccessor.getExecutionVertexOrThrow(ExecutionVertexID id) |
ExecutionVertex |
IntermediateResultPartition.getProducer() |
ExecutionVertex[] |
ExecutionJobVertex.getTaskVertices() |
ExecutionVertex |
Execution.getVertex() |
Modifier and Type | Method and Description |
---|---|
Iterable<ExecutionVertex> |
DefaultExecutionGraph.getAllExecutionVertices() |
Iterable<ExecutionVertex> |
ExecutionGraph.getAllExecutionVertices() |
Constructor and Description |
---|
ArchivedExecutionVertex(ExecutionVertex vertex) |
Execution(Executor executor,
ExecutionVertex vertex,
int attemptNumber,
long startTimestamp,
Time rpcTimeout)
Creates a new Execution attempt.
|
IntermediateResultPartition(IntermediateResult totalResult,
ExecutionVertex producer,
int partitionNumber,
EdgeManager edgeManager) |
Modifier and Type | Method and Description |
---|---|
ExecutionVertex |
SchedulerBase.getExecutionVertex(ExecutionVertexID executionVertexId) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.