public class JobDispatcherFactory extends Object implements DispatcherFactory<MiniDispatcher>
DispatcherFactory
which creates a MiniDispatcher
.Constructor and Description |
---|
JobDispatcherFactory(JobGraphRetriever jobGraphRetriever) |
Modifier and Type | Method and Description |
---|---|
MiniDispatcher |
createDispatcher(Configuration configuration,
RpcService rpcService,
HighAvailabilityServices highAvailabilityServices,
GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever,
BlobServer blobServer,
HeartbeatServices heartbeatServices,
JobManagerMetricGroup jobManagerMetricGroup,
String metricQueryServicePath,
ArchivedExecutionGraphStore archivedExecutionGraphStore,
FatalErrorHandler fatalErrorHandler,
HistoryServerArchivist historyServerArchivist)
Create a
Dispatcher of the given type T . |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
generateEndpointIdWithUUID, getEndpointId
public JobDispatcherFactory(JobGraphRetriever jobGraphRetriever)
public MiniDispatcher createDispatcher(Configuration configuration, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, BlobServer blobServer, HeartbeatServices heartbeatServices, JobManagerMetricGroup jobManagerMetricGroup, @Nullable String metricQueryServicePath, ArchivedExecutionGraphStore archivedExecutionGraphStore, FatalErrorHandler fatalErrorHandler, HistoryServerArchivist historyServerArchivist) throws Exception
DispatcherFactory
Dispatcher
of the given type T
.createDispatcher
in interface DispatcherFactory<MiniDispatcher>
Exception
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.