public class FineGrainedTaskManagerRegistration extends Object implements TaskManagerInfo
FineGrainedSlotManager
.Constructor and Description |
---|
FineGrainedTaskManagerRegistration(TaskExecutorConnection taskManagerConnection,
ResourceProfile totalResourceProfile,
ResourceProfile defaultSlotResourceProfile) |
Modifier and Type | Method and Description |
---|---|
void |
freeSlot(AllocationID allocationId) |
Map<AllocationID,TaskManagerSlotInformation> |
getAllocatedSlots()
Get allocated slots information.
|
ResourceProfile |
getAvailableResource()
Get the available resource.
|
int |
getDefaultNumSlots()
Get the default number of slots.
|
ResourceProfile |
getDefaultSlotResourceProfile()
Get the default slot resource profile.
|
long |
getIdleSince()
Get the timestamp when the last time becoming idle.
|
InstanceID |
getInstanceId()
Get the instanceId of this task manager.
|
TaskExecutorConnection |
getTaskExecutorConnection()
Get the taskExecutorConnection.
|
ResourceProfile |
getTotalResource()
Get the total resource.
|
boolean |
isIdle()
Check whether this task manager is idle.
|
void |
notifyAllocation(AllocationID allocationId,
FineGrainedTaskManagerSlot taskManagerSlot) |
void |
notifyAllocationComplete(AllocationID allocationId) |
public FineGrainedTaskManagerRegistration(TaskExecutorConnection taskManagerConnection, ResourceProfile totalResourceProfile, ResourceProfile defaultSlotResourceProfile)
public TaskExecutorConnection getTaskExecutorConnection()
TaskManagerInfo
getTaskExecutorConnection
in interface TaskManagerInfo
public InstanceID getInstanceId()
TaskManagerInfo
getInstanceId
in interface TaskManagerInfo
public Map<AllocationID,TaskManagerSlotInformation> getAllocatedSlots()
TaskManagerInfo
getAllocatedSlots
in interface TaskManagerInfo
public ResourceProfile getAvailableResource()
TaskManagerInfo
getAvailableResource
in interface TaskManagerInfo
public ResourceProfile getDefaultSlotResourceProfile()
TaskManagerInfo
getDefaultSlotResourceProfile
in interface TaskManagerInfo
public ResourceProfile getTotalResource()
TaskManagerInfo
getTotalResource
in interface TaskManagerInfo
public int getDefaultNumSlots()
TaskManagerInfo
getDefaultNumSlots
in interface TaskManagerInfo
public long getIdleSince()
TaskManagerInfo
getIdleSince
in interface TaskManagerInfo
public boolean isIdle()
TaskManagerInfo
isIdle
in interface TaskManagerInfo
public void freeSlot(AllocationID allocationId)
public void notifyAllocationComplete(AllocationID allocationId)
public void notifyAllocation(AllocationID allocationId, FineGrainedTaskManagerSlot taskManagerSlot)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.