T
- type of the ResourceIDRetrievable
public abstract class ActiveResourceManagerFactory<T extends ResourceIDRetrievable> extends Object implements ResourceManagerFactory<T>
ResourceManager
implementations.
The default implementation will call createActiveResourceManagerConfiguration(org.apache.flink.configuration.Configuration)
to create a new configuration which is configured with active resource manager relevant
configuration options.
Constructor and Description |
---|
ActiveResourceManagerFactory() |
Modifier and Type | Method and Description |
---|---|
protected abstract ResourceManager<T> |
createActiveResourceManager(Configuration configuration,
ResourceID resourceId,
RpcService rpcService,
HighAvailabilityServices highAvailabilityServices,
HeartbeatServices heartbeatServices,
FatalErrorHandler fatalErrorHandler,
ClusterInformation clusterInformation,
String webInterfaceUrl,
ResourceManagerMetricGroup resourceManagerMetricGroup) |
static Configuration |
createActiveResourceManagerConfiguration(Configuration originalConfiguration) |
ResourceManager<T> |
createResourceManager(Configuration configuration,
ResourceID resourceId,
RpcService rpcService,
HighAvailabilityServices highAvailabilityServices,
HeartbeatServices heartbeatServices,
FatalErrorHandler fatalErrorHandler,
ClusterInformation clusterInformation,
String webInterfaceUrl,
ResourceManagerMetricGroup resourceManagerMetricGroup) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
generateEndpointIdWithUUID, getEndpointId
public ResourceManager<T> createResourceManager(Configuration configuration, ResourceID resourceId, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, @Nullable String webInterfaceUrl, ResourceManagerMetricGroup resourceManagerMetricGroup) throws Exception
createResourceManager
in interface ResourceManagerFactory<T extends ResourceIDRetrievable>
Exception
public static Configuration createActiveResourceManagerConfiguration(Configuration originalConfiguration)
protected abstract ResourceManager<T> createActiveResourceManager(Configuration configuration, ResourceID resourceId, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, @Nullable String webInterfaceUrl, ResourceManagerMetricGroup resourceManagerMetricGroup) throws Exception
Exception
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.