Package org.apache.flink.runtime.resourcemanager

Class WorkerResourceSpecFactory

java.lang.Object

org.apache.flink.runtime.resourcemanager.WorkerResourceSpecFactory

Direct Known Subclasses:

ArbitraryWorkerResourceSpecFactory, KubernetesWorkerResourceSpecFactory, YarnWorkerResourceSpecFactory

public abstract class WorkerResourceSpecFactory
extends Object

Factory for creating deployment specific default WorkerResourceSpec.

Constructor Summary

Constructors

Constructor	Description
WorkerResourceSpecFactory()

Method Summary

Modifier and Type	Method	Description
abstract WorkerResourceSpec	createDefaultWorkerResourceSpec(Configuration configuration)
protected WorkerResourceSpec	workerResourceSpecFromConfigAndCpu(Configuration configuration, CPUResource cpuResource)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WorkerResourceSpecFactory

public WorkerResourceSpecFactory()

Method Detail

createDefaultWorkerResourceSpec

public abstract WorkerResourceSpec createDefaultWorkerResourceSpec(Configuration configuration)

workerResourceSpecFromConfigAndCpu

protected WorkerResourceSpec workerResourceSpecFromConfigAndCpu(Configuration configuration,
                                                                CPUResource cpuResource)