public abstract class ActiveResourceManagerFactory<WorkerType extends ResourceIDRetrievable> extends ResourceManagerFactory<WorkerType>
ActiveResourceManager
with various implementations of ResourceManagerDriver
.Constructor and Description |
---|
ActiveResourceManagerFactory() |
Modifier and Type | Method and Description |
---|---|
ResourceManager<WorkerType> |
createResourceManager(Configuration configuration,
ResourceID resourceId,
RpcService rpcService,
HighAvailabilityServices highAvailabilityServices,
HeartbeatServices heartbeatServices,
FatalErrorHandler fatalErrorHandler,
ClusterInformation clusterInformation,
String webInterfaceUrl,
MetricRegistry metricRegistry,
String hostname,
Executor ioExecutor) |
ResourceManager<WorkerType> |
createResourceManager(Configuration configuration,
ResourceID resourceId,
RpcService rpcService,
HighAvailabilityServices highAvailabilityServices,
HeartbeatServices heartbeatServices,
FatalErrorHandler fatalErrorHandler,
ClusterInformation clusterInformation,
String webInterfaceUrl,
ResourceManagerMetricGroup resourceManagerMetricGroup,
ResourceManagerRuntimeServices resourceManagerRuntimeServices,
Executor ioExecutor) |
protected abstract ResourceManagerDriver<WorkerType> |
createResourceManagerDriver(Configuration configuration,
String webInterfaceUrl,
String rpcAddress) |
createResourceManagerRuntimeServicesConfiguration
public ResourceManager<WorkerType> createResourceManager(Configuration configuration, ResourceID resourceId, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, @Nullable String webInterfaceUrl, MetricRegistry metricRegistry, String hostname, Executor ioExecutor) throws Exception
createResourceManager
in class ResourceManagerFactory<WorkerType extends ResourceIDRetrievable>
Exception
public ResourceManager<WorkerType> createResourceManager(Configuration configuration, ResourceID resourceId, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, @Nullable String webInterfaceUrl, ResourceManagerMetricGroup resourceManagerMetricGroup, ResourceManagerRuntimeServices resourceManagerRuntimeServices, Executor ioExecutor) throws Exception
createResourceManager
in class ResourceManagerFactory<WorkerType extends ResourceIDRetrievable>
Exception
protected abstract ResourceManagerDriver<WorkerType> createResourceManagerDriver(Configuration configuration, @Nullable String webInterfaceUrl, String rpcAddress) throws Exception
Exception
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.