public class TaskManagerSlot extends Object implements TaskManagerSlotInformation
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,
JobID jobId) |
void |
freeSlot() |
AllocationID |
getAllocationId() |
PendingSlotRequest |
getAssignedSlotRequest() |
InstanceID |
getInstanceId() |
JobID |
getJobId() |
ResourceProfile |
getResourceProfile()
Get resource profile of this slot.
|
SlotID |
getSlotId() |
org.apache.flink.runtime.resourcemanager.slotmanager.SlotState |
getState() |
TaskExecutorConnection |
getTaskManagerConnection() |
void |
updateAllocation(AllocationID allocationId,
JobID jobId) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
isMatchingRequirement
public TaskManagerSlot(SlotID slotId, ResourceProfile resourceProfile, TaskExecutorConnection taskManagerConnection)
public org.apache.flink.runtime.resourcemanager.slotmanager.SlotState getState()
getState
in interface TaskManagerSlotInformation
public SlotID getSlotId()
getSlotId
in interface TaskManagerSlotInformation
public ResourceProfile getResourceProfile()
TaskManagerSlotInformation
getResourceProfile
in interface TaskManagerSlotInformation
public TaskExecutorConnection getTaskManagerConnection()
getTaskManagerConnection
in interface TaskManagerSlotInformation
@Nullable public AllocationID getAllocationId()
getAllocationId
in interface TaskManagerSlotInformation
@Nullable public JobID getJobId()
getJobId
in interface TaskManagerSlotInformation
public PendingSlotRequest getAssignedSlotRequest()
public InstanceID getInstanceId()
getInstanceId
in interface TaskManagerSlotInformation
public void freeSlot()
public void clearPendingSlotRequest()
public void assignPendingSlotRequest(PendingSlotRequest pendingSlotRequest)
public void completeAllocation(AllocationID allocationId, JobID jobId)
public void updateAllocation(AllocationID allocationId, JobID jobId)
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.