public class DispatcherServices extends Object
Dispatcher
services container.Constructor and Description |
---|
DispatcherServices(Configuration configuration,
HighAvailabilityServices highAvailabilityServices,
GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever,
BlobServer blobServer,
HeartbeatServices heartbeatServices,
ArchivedExecutionGraphStore archivedExecutionGraphStore,
FatalErrorHandler fatalErrorHandler,
HistoryServerArchivist historyServerArchivist,
String metricQueryServiceAddress,
JobManagerMetricGroup jobManagerMetricGroup,
JobGraphWriter jobGraphWriter,
JobManagerRunnerFactory jobManagerRunnerFactory,
Executor ioExecutor) |
Modifier and Type | Method and Description |
---|---|
static DispatcherServices |
from(PartialDispatcherServicesWithJobGraphStore partialDispatcherServicesWithJobGraphStore,
JobManagerRunnerFactory jobManagerRunnerFactory) |
ArchivedExecutionGraphStore |
getArchivedExecutionGraphStore() |
BlobServer |
getBlobServer() |
Configuration |
getConfiguration() |
FatalErrorHandler |
getFatalErrorHandler() |
HeartbeatServices |
getHeartbeatServices() |
HighAvailabilityServices |
getHighAvailabilityServices() |
HistoryServerArchivist |
getHistoryServerArchivist() |
Executor |
getIoExecutor() |
JobGraphWriter |
getJobGraphWriter() |
JobManagerMetricGroup |
getJobManagerMetricGroup() |
String |
getMetricQueryServiceAddress() |
GatewayRetriever<ResourceManagerGateway> |
getResourceManagerGatewayRetriever() |
public DispatcherServices(@Nonnull Configuration configuration, @Nonnull HighAvailabilityServices highAvailabilityServices, @Nonnull GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, @Nonnull BlobServer blobServer, @Nonnull HeartbeatServices heartbeatServices, @Nonnull ArchivedExecutionGraphStore archivedExecutionGraphStore, @Nonnull FatalErrorHandler fatalErrorHandler, @Nonnull HistoryServerArchivist historyServerArchivist, @Nullable String metricQueryServiceAddress, @Nonnull JobManagerMetricGroup jobManagerMetricGroup, @Nonnull JobGraphWriter jobGraphWriter, @Nonnull JobManagerRunnerFactory jobManagerRunnerFactory, @Nonnull Executor ioExecutor)
@Nonnull public Configuration getConfiguration()
@Nonnull public HighAvailabilityServices getHighAvailabilityServices()
@Nonnull public GatewayRetriever<ResourceManagerGateway> getResourceManagerGatewayRetriever()
@Nonnull public BlobServer getBlobServer()
@Nonnull public HeartbeatServices getHeartbeatServices()
@Nonnull public JobManagerMetricGroup getJobManagerMetricGroup()
@Nonnull public ArchivedExecutionGraphStore getArchivedExecutionGraphStore()
@Nonnull public FatalErrorHandler getFatalErrorHandler()
@Nonnull public HistoryServerArchivist getHistoryServerArchivist()
@Nonnull public JobGraphWriter getJobGraphWriter()
public static DispatcherServices from(@Nonnull PartialDispatcherServicesWithJobGraphStore partialDispatcherServicesWithJobGraphStore, @Nonnull JobManagerRunnerFactory jobManagerRunnerFactory)
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.