org.apache.flink.yarn.entrypoint

Class YarnWorkerResourceSpecFactory

java.lang.Object

org.apache.flink.runtime.resourcemanager.WorkerResourceSpecFactory

org.apache.flink.yarn.entrypoint.YarnWorkerResourceSpecFactory

public class YarnWorkerResourceSpecFactory
extends WorkerResourceSpecFactory

Implementation of WorkerResourceSpecFactory for Yarn deployments.

Field Summary

Fields

Modifier and Type	Field and Description
static YarnWorkerResourceSpecFactory	INSTANCE

Method Summary

Modifier and Type	Method and Description
WorkerResourceSpec	createDefaultWorkerResourceSpec(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 YarnWorkerResourceSpecFactory INSTANCE

Method Detail

createDefaultWorkerResourceSpec

public WorkerResourceSpec createDefaultWorkerResourceSpec(Configuration configuration)

Specified by:

createDefaultWorkerResourceSpec in class WorkerResourceSpecFactory