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(Duration jobTimeout, SlotManagerConfiguration slotManagerConfiguration)

Method Summary

Modifier and Type	Method	Description
static ResourceManagerRuntimeServicesConfiguration	fromConfiguration(Configuration configuration, WorkerResourceSpecFactory defaultWorkerResourceSpecFactory)
Duration	getJobTimeout()
SlotManagerConfiguration	getSlotManagerConfiguration()

Methods inherited from class java.lang.Object

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

Constructor Detail

ResourceManagerRuntimeServicesConfiguration

public ResourceManagerRuntimeServicesConfiguration(Duration jobTimeout,
                                                   SlotManagerConfiguration slotManagerConfiguration)

Method Detail

getJobTimeout

public Duration getJobTimeout()

getSlotManagerConfiguration

public SlotManagerConfiguration getSlotManagerConfiguration()

fromConfiguration

public static ResourceManagerRuntimeServicesConfiguration fromConfiguration(Configuration configuration,
                                                                            WorkerResourceSpecFactory defaultWorkerResourceSpecFactory)
                                                                     throws ConfigurationException

Throws:

ConfigurationException