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() |
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, MetricRegistry metricRegistry, FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, @Nullable String webInterfaceUrl, JobManagerMetricGroup jobManagerMetricGroup) 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, MetricRegistry metricRegistry, FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, @Nullable String webInterfaceUrl, JobManagerMetricGroup jobManagerMetricGroup) throws Exception
Exception
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.