Package | Description |
---|---|
org.apache.flink.runtime.taskexecutor.slot |
Modifier and Type | Method and Description |
---|---|
boolean |
TaskSlotTable.addTask(Task task)
Add the given task to the slot identified by the task's allocation id.
|
int |
TaskSlotTable.freeSlot(AllocationID allocationId)
Try to free the slot.
|
int |
TaskSlotTable.freeSlot(AllocationID allocationId,
Throwable cause)
Tries to free the slot.
|
boolean |
TaskSlotTable.markSlotActive(AllocationID allocationId)
Marks the slot under the given allocation id as active.
|
boolean |
TaskSlotTable.markSlotInactive(AllocationID allocationId,
Time slotTimeout)
Marks the slot under the given allocation id as inactive.
|
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.