Modifier and Type | Method and Description |
---|---|
LogicalSlot |
Execution.getAssignedResource() |
LogicalSlot |
ExecutionVertex.getCurrentAssignedResource() |
Modifier and Type | Method and Description |
---|---|
void |
ExecutionVertex.deployToSlot(LogicalSlot slot) |
Modifier and Type | Class and Description |
---|---|
class |
SharedSlot
This class represents a shared slot.
|
class |
SimpleSlot
A SimpleSlot represents a single slot on a TaskManager instance, or a slot within a shared slot.
|
Modifier and Type | Method and Description |
---|---|
void |
Instance.returnLogicalSlot(LogicalSlot logicalSlot)
Returns a slot that has been allocated from this instance.
|
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,
boolean allowQueuedScheduling)
Allocating batch slot with specific requirement.
|
CompletableFuture<LogicalSlot> |
SchedulerImpl.allocateBatchSlot(SlotRequestId slotRequestId,
ScheduledUnit scheduledUnit,
SlotProfile slotProfile,
boolean allowQueuedScheduling) |
default CompletableFuture<LogicalSlot> |
SlotProvider.allocateSlot(ScheduledUnit scheduledUnit,
boolean allowQueued,
SlotProfile slotProfile,
Time allocationTimeout)
Allocating slot with specific requirement.
|
CompletableFuture<LogicalSlot> |
SlotProvider.allocateSlot(SlotRequestId slotRequestId,
ScheduledUnit scheduledUnit,
SlotProfile slotProfile,
boolean allowQueuedScheduling,
Time allocationTimeout)
Allocating slot with specific requirement.
|
CompletableFuture<LogicalSlot> |
SchedulerImpl.allocateSlot(SlotRequestId slotRequestId,
ScheduledUnit scheduledUnit,
SlotProfile slotProfile,
boolean allowQueuedScheduling,
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–2020 The Apache Software Foundation. All rights reserved.