public class FineGrainedTaskManagerSlot extends Object implements TaskManagerSlotInformation
FineGrainedSlotManager
.
Note that it should not in the state of SlotState.FREE
.
Constructor and Description |
---|
FineGrainedTaskManagerSlot(AllocationID allocationId,
JobID jobId,
ResourceProfile resourceProfile,
TaskExecutorConnection taskManagerConnection,
org.apache.flink.runtime.resourcemanager.slotmanager.SlotState slotState) |
Modifier and Type | Method and Description |
---|---|
void |
completeAllocation() |
AllocationID |
getAllocationId() |
InstanceID |
getInstanceId() |
JobID |
getJobId() |
ResourceProfile |
getResourceProfile()
Get resource profile of this slot.
|
SlotID |
getSlotId() |
org.apache.flink.runtime.resourcemanager.slotmanager.SlotState |
getState() |
TaskExecutorConnection |
getTaskManagerConnection() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
isMatchingRequirement
public FineGrainedTaskManagerSlot(AllocationID allocationId, JobID jobId, ResourceProfile resourceProfile, TaskExecutorConnection taskManagerConnection, org.apache.flink.runtime.resourcemanager.slotmanager.SlotState slotState)
public ResourceProfile getResourceProfile()
TaskManagerSlotInformation
getResourceProfile
in interface TaskManagerSlotInformation
public org.apache.flink.runtime.resourcemanager.slotmanager.SlotState getState()
getState
in interface TaskManagerSlotInformation
public JobID getJobId()
getJobId
in interface TaskManagerSlotInformation
public AllocationID getAllocationId()
getAllocationId
in interface TaskManagerSlotInformation
public SlotID getSlotId()
getSlotId
in interface TaskManagerSlotInformation
public InstanceID getInstanceId()
getInstanceId
in interface TaskManagerSlotInformation
public TaskExecutorConnection getTaskManagerConnection()
getTaskManagerConnection
in interface TaskManagerSlotInformation
public void completeAllocation()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.