Package | Description |
---|---|
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.jobmaster | |
org.apache.flink.runtime.jobmaster.slotpool | |
org.apache.flink.runtime.scheduler |
Modifier and Type | Method and Description |
---|---|
LogicalSlot |
Execution.getAssignedResource() |
LogicalSlot |
ExecutionVertex.getCurrentAssignedResource() |
Modifier and Type | Method and Description |
---|---|
abstract CompletableFuture<LogicalSlot> |
SlotProviderStrategy.allocateSlot(SlotRequestId slotRequestId,
ScheduledUnit scheduledUnit,
SlotProfile slotProfile)
Allocating slot with specific requirement.
|
Modifier and Type | Method and Description |
---|---|
void |
ExecutionVertex.deployToSlot(LogicalSlot slot) |
boolean |
Execution.tryAssignResource(LogicalSlot logicalSlot)
Tries to assign the given slot to the execution.
|
void |
ExecutionVertex.tryAssignResource(LogicalSlot slot) |
Modifier and Type | Method and Description |
---|---|
void |
SlotOwner.returnLogicalSlot(LogicalSlot logicalSlot)
Return the given slot to the slot owner.
|
Modifier and Type | Class and Description |
---|---|
class |
SingleLogicalSlot
Implementation of the
LogicalSlot which is used by the SlotPoolImpl . |
Modifier and Type | Method and Description |
---|---|
default CompletableFuture<LogicalSlot> |
SlotProvider.allocateBatchSlot(SlotRequestId slotRequestId,
ScheduledUnit scheduledUnit,
SlotProfile slotProfile)
Allocating batch slot with specific requirement.
|
CompletableFuture<LogicalSlot> |
SchedulerImpl.allocateBatchSlot(SlotRequestId slotRequestId,
ScheduledUnit scheduledUnit,
SlotProfile slotProfile) |
default CompletableFuture<LogicalSlot> |
SlotProvider.allocateSlot(ScheduledUnit scheduledUnit,
SlotProfile slotProfile,
Time allocationTimeout)
Allocating slot with specific requirement.
|
CompletableFuture<LogicalSlot> |
ThrowingSlotProvider.allocateSlot(SlotRequestId slotRequestId,
ScheduledUnit scheduledUnit,
SlotProfile slotProfile,
Time allocationTimeout) |
CompletableFuture<LogicalSlot> |
SlotProvider.allocateSlot(SlotRequestId slotRequestId,
ScheduledUnit scheduledUnit,
SlotProfile slotProfile,
Time allocationTimeout)
Allocating slot with specific requirement.
|
CompletableFuture<LogicalSlot> |
SchedulerImpl.allocateSlot(SlotRequestId slotRequestId,
ScheduledUnit scheduledUnit,
SlotProfile slotProfile,
Time allocationTimeout) |
Modifier and Type | Method and Description |
---|---|
void |
SchedulerImpl.returnLogicalSlot(LogicalSlot logicalSlot) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<LogicalSlot> |
SlotExecutionVertexAssignment.getLogicalSlotFuture() |
Constructor and Description |
---|
SlotExecutionVertexAssignment(ExecutionVertexID executionVertexId,
CompletableFuture<LogicalSlot> logicalSlotFuture) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.