Uses of Class
org.apache.flink.runtime.resourcemanager.WorkerResourceSpec

Packages that use WorkerResourceSpec

Package	Description
org.apache.flink.kubernetes.entrypoint
org.apache.flink.runtime.clusterframework	This package contains the cluster resource management functionality.
org.apache.flink.runtime.resourcemanager
org.apache.flink.runtime.resourcemanager.active
org.apache.flink.runtime.resourcemanager.slotmanager
org.apache.flink.yarn.entrypoint

Uses of WorkerResourceSpec in org.apache.flink.kubernetes.entrypoint

Methods in org.apache.flink.kubernetes.entrypoint that return WorkerResourceSpec

Modifier and Type	Method and Description
WorkerResourceSpec	KubernetesWorkerResourceSpecFactory.createDefaultWorkerResourceSpec(Configuration configuration)

Uses of WorkerResourceSpec in org.apache.flink.runtime.clusterframework

Methods in org.apache.flink.runtime.clusterframework with parameters of type WorkerResourceSpec

Modifier and Type	Method and Description
static TaskExecutorProcessSpec	TaskExecutorProcessUtils.processSpecFromWorkerResourceSpec(Configuration config, WorkerResourceSpec workerResourceSpec)

Uses of WorkerResourceSpec in org.apache.flink.runtime.resourcemanager

Fields in org.apache.flink.runtime.resourcemanager declared as WorkerResourceSpec

Modifier and Type	Field and Description
static WorkerResourceSpec	WorkerResourceSpec.ZERO

Methods in org.apache.flink.runtime.resourcemanager that return WorkerResourceSpec

Modifier and Type	Method and Description
WorkerResourceSpec	WorkerResourceSpec.Builder.build()
abstract WorkerResourceSpec	WorkerResourceSpecFactory.createDefaultWorkerResourceSpec(Configuration configuration)
WorkerResourceSpec	ArbitraryWorkerResourceSpecFactory.createDefaultWorkerResourceSpec(Configuration configuration)
static WorkerResourceSpec	WorkerResourceSpec.fromTaskExecutorProcessSpec(TaskExecutorProcessSpec taskExecutorProcessSpec)
static WorkerResourceSpec	WorkerResourceSpec.fromTotalResourceProfile(ResourceProfile resourceProfile, int numSlots)
protected WorkerResourceSpec	WorkerResourceSpecFactory.workerResourceSpecFromConfigAndCpu(Configuration configuration, CPUResource cpuResource)

Methods in org.apache.flink.runtime.resourcemanager that return types with arguments of type WorkerResourceSpec

Modifier and Type	Method and Description
protected Map<WorkerResourceSpec,Integer>	ResourceManager.getRequiredResources()

Methods in org.apache.flink.runtime.resourcemanager with parameters of type WorkerResourceSpec

Modifier and Type	Method and Description
boolean	StandaloneResourceManager.startNewWorker(WorkerResourceSpec workerResourceSpec)
abstract boolean	ResourceManager.startNewWorker(WorkerResourceSpec workerResourceSpec) Allocates a resource using the worker resource specification.

Uses of WorkerResourceSpec in org.apache.flink.runtime.resourcemanager.active

Methods in org.apache.flink.runtime.resourcemanager.active with parameters of type WorkerResourceSpec

Modifier and Type	Method and Description
boolean	ActiveResourceManager.startNewWorker(WorkerResourceSpec workerResourceSpec)

Uses of WorkerResourceSpec in org.apache.flink.runtime.resourcemanager.slotmanager

Methods in org.apache.flink.runtime.resourcemanager.slotmanager that return WorkerResourceSpec

Modifier and Type	Method and Description
WorkerResourceSpec	SlotManagerConfiguration.getDefaultWorkerResourceSpec()

Methods in org.apache.flink.runtime.resourcemanager.slotmanager that return types with arguments of type WorkerResourceSpec

Modifier and Type	Method and Description
Map<WorkerResourceSpec,Integer>	SlotManager.getRequiredResources() Get number of workers SlotManager requested from ResourceActions that are not yet fulfilled.
Map<WorkerResourceSpec,Integer>	DeclarativeSlotManager.getRequiredResources()
Map<WorkerResourceSpec,Integer>	FineGrainedSlotManager.getRequiredResources()

Methods in org.apache.flink.runtime.resourcemanager.slotmanager with parameters of type WorkerResourceSpec

Modifier and Type	Method and Description
boolean	ResourceActions.allocateResource(WorkerResourceSpec workerResourceSpec) Requests to allocate a resource with the given WorkerResourceSpec.
static SlotManagerConfiguration	SlotManagerConfiguration.fromConfiguration(Configuration configuration, WorkerResourceSpec defaultWorkerResourceSpec)
static ResourceProfile	SlotManagerUtils.generateDefaultSlotResourceProfile(WorkerResourceSpec workerResourceSpec, int numSlotsPerWorker) This must be consist with TaskExecutorResourceUtils.generateDefaultSlotResourceProfile(org.apache.flink.runtime.taskexecutor.TaskExecutorResourceSpec, int).
static ResourceProfile	SlotManagerUtils.generateTaskManagerTotalResourceProfile(WorkerResourceSpec workerResourceSpec)

Constructors in org.apache.flink.runtime.resourcemanager.slotmanager with parameters of type WorkerResourceSpec

Constructor and Description
SlotManagerConfiguration(Time taskManagerRequestTimeout, Time slotRequestTimeout, Time taskManagerTimeout, java.time.Duration requirementCheckDelay, boolean waitResultConsumedBeforeRelease, SlotMatchingStrategy slotMatchingStrategy, WorkerResourceSpec defaultWorkerResourceSpec, int numSlotsPerWorker, int maxSlotNum, CPUResource maxTotalCpu, MemorySize maxTotalMem, int redundantTaskManagerNum)

Uses of WorkerResourceSpec in org.apache.flink.yarn.entrypoint

Methods in org.apache.flink.yarn.entrypoint that return WorkerResourceSpec

Modifier and Type	Method and Description
WorkerResourceSpec	YarnWorkerResourceSpecFactory.createDefaultWorkerResourceSpec(Configuration configuration)