Package | Description |
---|---|
org.apache.flink.runtime.deployment | |
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.instance | |
org.apache.flink.runtime.jobmanager.scheduler |
Modifier and Type | Method and Description |
---|---|
InputChannelDeploymentDescriptor |
PartialInputChannelDeploymentDescriptor.createInputChannelDeploymentDescriptor(Execution consumerExecution)
Creates a channel deployment descriptor by completing the partition location.
|
static PartialInputChannelDeploymentDescriptor |
PartialInputChannelDeploymentDescriptor.fromEdge(IntermediateResultPartition partition,
Execution producer)
Creates a partial input channel for the given partition and producing task.
|
Modifier and Type | Method and Description |
---|---|
Execution |
ExecutionVertex.getCurrentExecutionAttempt() |
Execution |
ExecutionVertex.getPriorExecutionAttempt(int attemptNumber) |
Modifier and Type | Method and Description |
---|---|
Map<ExecutionAttemptID,Execution> |
ExecutionGraph.getRegisteredExecutions() |
Constructor and Description |
---|
ArchivedExecution(Execution execution) |
Modifier and Type | Method and Description |
---|---|
Execution |
SimpleSlot.getExecutedVertex()
Gets the task execution attempt currently executed in this slot.
|
Modifier and Type | Method and Description |
---|---|
boolean |
SimpleSlot.setExecutedVertex(Execution executedVertex)
Atomically sets the executed vertex, if no vertex has been assigned to this slot so far.
|
Modifier and Type | Method and Description |
---|---|
Execution |
ScheduledUnit.getTaskToExecute() |
Constructor and Description |
---|
ScheduledUnit(Execution task) |
ScheduledUnit(Execution task,
SlotSharingGroup sharingUnit) |
ScheduledUnit(Execution task,
SlotSharingGroup sharingUnit,
CoLocationConstraint locationConstraint) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.