Modifier and Type | Method and Description |
---|---|
LogicalSlot |
Execution.getAssignedResource() |
LogicalSlot |
ExecutionVertex.getCurrentAssignedResource() |
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 |
---|---|
CompletableFuture<Boolean> |
Instance.returnAllocatedSlot(LogicalSlot logicalSlot)
Returns a slot that has been allocated from this instance.
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<LogicalSlot> |
Scheduler.allocateSlot(SlotRequestId slotRequestId,
ScheduledUnit task,
boolean allowQueued,
SlotProfile slotProfile,
Time allocationTimeout) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Boolean> |
SlotOwner.returnAllocatedSlot(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 SlotPool . |
Modifier and Type | Method and Description |
---|---|
default CompletableFuture<LogicalSlot> |
SlotProvider.allocateSlot(ScheduledUnit task,
boolean allowQueued,
SlotProfile slotProfile,
Time timeout)
Allocating slot with specific requirement.
|
CompletableFuture<LogicalSlot> |
SlotProvider.allocateSlot(SlotRequestId slotRequestId,
ScheduledUnit task,
boolean allowQueued,
SlotProfile slotProfile,
Time timeout)
Allocating slot with specific requirement.
|
CompletableFuture<LogicalSlot> |
SlotPoolGateway.allocateSlot(SlotRequestId slotRequestId,
ScheduledUnit scheduledUnit,
SlotProfile slotProfile,
boolean allowQueuedScheduling,
Time timeout)
Requests to allocate a slot for the given
ScheduledUnit . |
CompletableFuture<LogicalSlot> |
SlotPool.allocateSlot(SlotRequestId slotRequestId,
ScheduledUnit task,
SlotProfile slotProfile,
boolean allowQueuedScheduling,
Time allocationTimeout) |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.