Package | Description |
---|---|
org.apache.flink.runtime.taskexecutor.slot |
Modifier and Type | Method and Description |
---|---|
boolean |
TaskSlotTable.addTask(T task)
Add the given task to the slot identified by the task's allocation id.
|
boolean |
TaskSlotTableImpl.addTask(T task) |
default int |
TaskSlotTable.freeSlot(AllocationID allocationId)
Try to free the slot.
|
int |
TaskSlotTable.freeSlot(AllocationID allocationId,
Throwable cause)
Tries to free the slot.
|
int |
TaskSlotTableImpl.freeSlot(AllocationID allocationId,
Throwable cause) |
MemoryManager |
TaskSlotTable.getTaskMemoryManager(AllocationID allocationID)
Get the memory manager of the slot allocated for the task.
|
MemoryManager |
TaskSlotTableImpl.getTaskMemoryManager(AllocationID allocationID) |
boolean |
TaskSlotTable.markSlotActive(AllocationID allocationId)
Marks the slot under the given allocation id as active.
|
boolean |
TaskSlotTableImpl.markSlotActive(AllocationID allocationId) |
boolean |
TaskSlotTable.markSlotInactive(AllocationID allocationId,
Duration slotTimeout)
Marks the slot under the given allocation id as inactive.
|
boolean |
TaskSlotTableImpl.markSlotInactive(AllocationID allocationId,
Duration slotTimeout) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.