Package org.apache.flink.runtime.resourcemanager

Class ResourceManagerRuntimeServicesConfiguration

java.lang.Object

org.apache.flink.runtime.resourcemanager.ResourceManagerRuntimeServicesConfiguration

public class ResourceManagerRuntimeServicesConfiguration
extends Object

Configuration class for the ResourceManagerRuntimeServices class.

Constructor Summary

Constructors

Constructor	Description
ResourceManagerRuntimeServicesConfiguration(org.apache.flink.api.common.time.Time jobTimeout, SlotManagerConfiguration slotManagerConfiguration, boolean enableFineGrainedResourceManagement)

Method Summary

Modifier and Type	Method	Description
static ResourceManagerRuntimeServicesConfiguration	fromConfiguration(org.apache.flink.configuration.Configuration configuration, WorkerResourceSpecFactory defaultWorkerResourceSpecFactory)
org.apache.flink.api.common.time.Time	getJobTimeout()
SlotManagerConfiguration	getSlotManagerConfiguration()
boolean	isEnableFineGrainedResourceManagement()

Methods inherited from class java.lang.Object

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

Constructor Detail

ResourceManagerRuntimeServicesConfiguration

public ResourceManagerRuntimeServicesConfiguration(org.apache.flink.api.common.time.Time jobTimeout,
                                                   SlotManagerConfiguration slotManagerConfiguration,
                                                   boolean enableFineGrainedResourceManagement)

Method Detail

getJobTimeout

public org.apache.flink.api.common.time.Time getJobTimeout()

getSlotManagerConfiguration

public SlotManagerConfiguration getSlotManagerConfiguration()

isEnableFineGrainedResourceManagement

public boolean isEnableFineGrainedResourceManagement()

fromConfiguration

public static ResourceManagerRuntimeServicesConfiguration fromConfiguration(org.apache.flink.configuration.Configuration configuration,
                                                                            WorkerResourceSpecFactory defaultWorkerResourceSpecFactory)
                                                                     throws org.apache.flink.util.ConfigurationException

Throws:

org.apache.flink.util.ConfigurationException