Package org.apache.flink.kubernetes.entrypoint

Class KubernetesWorkerResourceSpecFactory

java.lang.Object

org.apache.flink.runtime.resourcemanager.WorkerResourceSpecFactory

org.apache.flink.kubernetes.entrypoint.KubernetesWorkerResourceSpecFactory

public class KubernetesWorkerResourceSpecFactory
extends org.apache.flink.runtime.resourcemanager.WorkerResourceSpecFactory

Implementation of WorkerResourceSpecFactory for Kubernetes deployments.

Field Summary

Fields

Modifier and Type	Field	Description
static KubernetesWorkerResourceSpecFactory	INSTANCE

Method Summary

Modifier and Type	Method	Description
org.apache.flink.runtime.resourcemanager.WorkerResourceSpec	createDefaultWorkerResourceSpec(org.apache.flink.configuration.Configuration configuration)

Methods inherited from class org.apache.flink.runtime.resourcemanager.WorkerResourceSpecFactory

workerResourceSpecFromConfigAndCpu

Methods inherited from class java.lang.Object

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

Field Detail

INSTANCE

public static final KubernetesWorkerResourceSpecFactory INSTANCE

Method Detail

createDefaultWorkerResourceSpec

public org.apache.flink.runtime.resourcemanager.WorkerResourceSpec createDefaultWorkerResourceSpec(org.apache.flink.configuration.Configuration configuration)

Specified by:

createDefaultWorkerResourceSpec in class org.apache.flink.runtime.resourcemanager.WorkerResourceSpecFactory