Package org.apache.flink.runtime.resourcemanager

Class ResourceManagerRuntimeServices

java.lang.Object

org.apache.flink.runtime.resourcemanager.ResourceManagerRuntimeServices

public class ResourceManagerRuntimeServices
extends Object

Container class for the ResourceManager services.

Constructor Summary

Constructors

Constructor	Description
ResourceManagerRuntimeServices(SlotManager slotManager, JobLeaderIdService jobLeaderIdService)

Method Summary

Modifier and Type	Method	Description
static ResourceManagerRuntimeServices	fromConfiguration(ResourceManagerRuntimeServicesConfiguration configuration, HighAvailabilityServices highAvailabilityServices, ScheduledExecutor scheduledExecutor, SlotManagerMetricGroup slotManagerMetricGroup)
JobLeaderIdService	getJobLeaderIdService()
SlotManager	getSlotManager()

Methods inherited from class java.lang.Object

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

Constructor Detail

ResourceManagerRuntimeServices

public ResourceManagerRuntimeServices(SlotManager slotManager,
                                      JobLeaderIdService jobLeaderIdService)

Method Detail

getSlotManager

public SlotManager getSlotManager()

getJobLeaderIdService

public JobLeaderIdService getJobLeaderIdService()

fromConfiguration

public static ResourceManagerRuntimeServices fromConfiguration(ResourceManagerRuntimeServicesConfiguration configuration,
                                                               HighAvailabilityServices highAvailabilityServices,
                                                               ScheduledExecutor scheduledExecutor,
                                                               SlotManagerMetricGroup slotManagerMetricGroup)