PendingTaskManager (Flink : 1.20-SNAPSHOT API)

```
public class PendingTaskManager
extends Object
```
Represents a pending task manager in the SlotManager.

Constructors
Constructor and Description
`PendingTaskManager(ResourceProfile totalResourceProfile, int numSlots)`

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`clearAllPendingAllocations()`
`void`	`clearPendingAllocationsOfJob(JobID jobId)`
`ResourceProfile`	`getDefaultSlotResourceProfile()`
`int`	`getNumSlots()`
`Map<JobID,ResourceCounter>`	`getPendingSlotAllocationRecords()`
`PendingTaskManagerId`	`getPendingTaskManagerId()`
`ResourceProfile`	`getTotalResourceProfile()`
`ResourceProfile`	`getUnusedResource()`
`void`	`replaceAllPendingAllocations(Map<JobID,ResourceCounter> pendingSlotAllocations)`
`String`	`toString()`

public PendingTaskManager(ResourceProfile totalResourceProfile,
                          int numSlots)

public ResourceProfile getTotalResourceProfile()

public ResourceProfile getDefaultSlotResourceProfile()

public PendingTaskManagerId getPendingTaskManagerId()

public ResourceProfile getUnusedResource()

public Map<JobID,ResourceCounter> getPendingSlotAllocationRecords()

public void clearAllPendingAllocations()

public void replaceAllPendingAllocations(Map<JobID,ResourceCounter> pendingSlotAllocations)

public void clearPendingAllocationsOfJob(JobID jobId)

Back to Flink Website