T
- type of the Dispatcher
U
- type of the RestfulGateway
given to the WebMonitorEndpoint
public abstract class AbstractDispatcherResourceManagerComponentFactory<T extends Dispatcher,U extends RestfulGateway> extends Object implements DispatcherResourceManagerComponentFactory<T>
DispatcherResourceManagerComponent
components.Constructor and Description |
---|
AbstractDispatcherResourceManagerComponentFactory(DispatcherFactory<T> dispatcherFactory,
ResourceManagerFactory<?> resourceManagerFactory,
RestEndpointFactory<U> restEndpointFactory) |
Modifier and Type | Method and Description |
---|---|
DispatcherResourceManagerComponent<T> |
create(Configuration configuration,
Executor ioExecutor,
RpcService rpcService,
HighAvailabilityServices highAvailabilityServices,
BlobServer blobServer,
HeartbeatServices heartbeatServices,
MetricRegistry metricRegistry,
ArchivedExecutionGraphStore archivedExecutionGraphStore,
MetricQueryServiceRetriever metricQueryServiceRetriever,
FatalErrorHandler fatalErrorHandler) |
protected abstract DispatcherResourceManagerComponent<T> |
createDispatcherResourceManagerComponent(T dispatcher,
ResourceManager<?> resourceManager,
LeaderRetrievalService dispatcherLeaderRetrievalService,
LeaderRetrievalService resourceManagerRetrievalService,
WebMonitorEndpoint<?> webMonitorEndpoint,
JobManagerMetricGroup jobManagerMetricGroup) |
protected String |
getHostname(RpcService rpcService) |
public AbstractDispatcherResourceManagerComponentFactory(@Nonnull DispatcherFactory<T> dispatcherFactory, @Nonnull ResourceManagerFactory<?> resourceManagerFactory, @Nonnull RestEndpointFactory<U> restEndpointFactory)
public DispatcherResourceManagerComponent<T> create(Configuration configuration, Executor ioExecutor, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, BlobServer blobServer, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, ArchivedExecutionGraphStore archivedExecutionGraphStore, MetricQueryServiceRetriever metricQueryServiceRetriever, FatalErrorHandler fatalErrorHandler) throws Exception
create
in interface DispatcherResourceManagerComponentFactory<T extends Dispatcher>
Exception
protected String getHostname(RpcService rpcService)
protected abstract DispatcherResourceManagerComponent<T> createDispatcherResourceManagerComponent(T dispatcher, ResourceManager<?> resourceManager, LeaderRetrievalService dispatcherLeaderRetrievalService, LeaderRetrievalService resourceManagerRetrievalService, WebMonitorEndpoint<?> webMonitorEndpoint, JobManagerMetricGroup jobManagerMetricGroup)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.