Package | Description |
---|---|
org.apache.flink.runtime.resourcemanager.slotmanager | |
org.apache.flink.runtime.slots |
Modifier and Type | Method and Description |
---|---|
Collection<ResourceRequirement> |
ResourceTracker.getAcquiredResources(JobID jobId)
Returns a collection of
ResourceRequirement s that describe which resources have been
assigned to a job. |
Collection<ResourceRequirement> |
DefaultResourceTracker.getAcquiredResources(JobID jobId) |
Map<JobID,Collection<ResourceRequirement>> |
ResourceTracker.getMissingResources()
Returns a collection of
ResourceRequirements that describe which resources the
corresponding job is missing. |
Map<JobID,Collection<ResourceRequirement>> |
DefaultResourceTracker.getMissingResources() |
Modifier and Type | Method and Description |
---|---|
void |
ResourceActions.notifyNotEnoughResourcesAvailable(JobID jobId,
Collection<ResourceRequirement> acquiredResources)
Notifies that not enough resources are available to fulfill the resource requirements of a
job.
|
void |
ResourceTracker.notifyResourceRequirements(JobID jobId,
Collection<ResourceRequirement> resourceRequirements)
Notifies the tracker about a new or updated
ResourceRequirements . |
void |
DefaultResourceTracker.notifyResourceRequirements(JobID jobId,
Collection<ResourceRequirement> resourceRequirements) |
Modifier and Type | Method and Description |
---|---|
static ResourceRequirement |
ResourceRequirement.create(ResourceProfile resourceProfile,
int numberOfRequiredSlots) |
Modifier and Type | Method and Description |
---|---|
Collection<ResourceRequirement> |
ResourceRequirements.getResourceRequirements() |
Modifier and Type | Method and Description |
---|---|
static ResourceRequirements |
ResourceRequirements.create(JobID jobId,
String targetAddress,
Collection<ResourceRequirement> resourceRequirements) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.