public interface DispatcherFactory<T extends Dispatcher>
Dispatcher
factory interface.Modifier and Type | Method and Description |
---|---|
T |
createDispatcher(Configuration configuration,
RpcService rpcService,
HighAvailabilityServices highAvailabilityServices,
GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever,
BlobServer blobServer,
HeartbeatServices heartbeatServices,
JobManagerMetricGroup jobManagerMetricGroup,
String metricQueryServiceAddress,
ArchivedExecutionGraphStore archivedExecutionGraphStore,
FatalErrorHandler fatalErrorHandler,
HistoryServerArchivist historyServerArchivist)
Create a
Dispatcher of the given type T . |
default String |
generateEndpointIdWithUUID() |
default String |
getEndpointId() |
T createDispatcher(Configuration configuration, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, BlobServer blobServer, HeartbeatServices heartbeatServices, JobManagerMetricGroup jobManagerMetricGroup, @Nullable String metricQueryServiceAddress, ArchivedExecutionGraphStore archivedExecutionGraphStore, FatalErrorHandler fatalErrorHandler, HistoryServerArchivist historyServerArchivist) throws Exception
Dispatcher
of the given type T
.Exception
default String generateEndpointIdWithUUID()
default String getEndpointId()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.