public class TaskManagerSlot extends Object
Modifier and Type | Class and Description |
---|---|
static class |
TaskManagerSlot.State |
Constructor and Description |
---|
TaskManagerSlot(SlotID slotId,
ResourceProfile resourceProfile,
TaskExecutorConnection taskManagerConnection) |
Modifier and Type | Method and Description |
---|---|
void |
assignPendingSlotRequest(PendingSlotRequest pendingSlotRequest) |
void |
clearPendingSlotRequest() |
void |
completeAllocation(AllocationID allocationId) |
void |
freeSlot() |
AllocationID |
getAllocationId() |
PendingSlotRequest |
getAssignedSlotRequest() |
InstanceID |
getInstanceId() |
ResourceProfile |
getResourceProfile() |
SlotID |
getSlotId() |
TaskManagerSlot.State |
getState() |
TaskExecutorConnection |
getTaskManagerConnection() |
boolean |
isMatchingRequirement(ResourceProfile required)
Check whether required resource profile can be matched by this slot.
|
void |
updateAllocation(AllocationID allocationId) |
public TaskManagerSlot(SlotID slotId, ResourceProfile resourceProfile, TaskExecutorConnection taskManagerConnection)
public TaskManagerSlot.State getState()
public SlotID getSlotId()
public ResourceProfile getResourceProfile()
public TaskExecutorConnection getTaskManagerConnection()
public AllocationID getAllocationId()
public PendingSlotRequest getAssignedSlotRequest()
public InstanceID getInstanceId()
public void freeSlot()
public void clearPendingSlotRequest()
public void assignPendingSlotRequest(PendingSlotRequest pendingSlotRequest)
public void completeAllocation(AllocationID allocationId)
public void updateAllocation(AllocationID allocationId)
public boolean isMatchingRequirement(ResourceProfile required)
required
- The required resource profileCopyright © 2014–2018 The Apache Software Foundation. All rights reserved.