public interface LogicalSlot
Modifier and Type | Interface and Description |
---|---|
static interface |
LogicalSlot.Payload
Payload for a logical slot.
|
Modifier and Type | Field and Description |
---|---|
static LogicalSlot.Payload |
TERMINATED_PAYLOAD |
Modifier and Type | Method and Description |
---|---|
AllocationID |
getAllocationId()
Gets the allocation id of this slot.
|
Locality |
getLocality()
Gets the locality of this slot.
|
LogicalSlot.Payload |
getPayload()
Returns the set payload or null if none.
|
SlotRequestId |
getSlotRequestId()
Gets the slot request id uniquely identifying the request with which this slot has been
allocated.
|
TaskManagerGateway |
getTaskManagerGateway()
Return the TaskManager gateway to talk to the TaskManager.
|
TaskManagerLocation |
getTaskManagerLocation()
Return the TaskManager location of this slot.
|
boolean |
isAlive()
True if the slot is alive and has not been released.
|
default CompletableFuture<?> |
releaseSlot()
Deprecated.
Added because extended the actual releaseSlot method with cause parameter.
|
CompletableFuture<?> |
releaseSlot(Throwable cause)
Releases this slot.
|
boolean |
tryAssignPayload(LogicalSlot.Payload payload)
Tries to assign a payload to this slot.
|
static final LogicalSlot.Payload TERMINATED_PAYLOAD
TaskManagerLocation getTaskManagerLocation()
TaskManagerGateway getTaskManagerGateway()
Locality getLocality()
boolean isAlive()
boolean tryAssignPayload(LogicalSlot.Payload payload)
payload
- to be assigned to this slot.@Nullable LogicalSlot.Payload getPayload()
default CompletableFuture<?> releaseSlot()
CompletableFuture<?> releaseSlot(@Nullable Throwable cause)
cause
- why the slot was released or null if noneAllocationID getAllocationId()
SlotRequestId getSlotRequestId()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.