public class DispatcherServices extends Object
Dispatcher
services container.Modifier and Type | Method and Description |
---|---|
static DispatcherServices |
from(PartialDispatcherServicesWithJobPersistenceComponents partialDispatcherServicesWithJobPersistenceComponents,
JobManagerRunnerFactory jobManagerRunnerFactory,
CleanupRunnerFactory cleanupRunnerFactory) |
ExecutionGraphInfoStore |
getArchivedExecutionGraphStore() |
BlobServer |
getBlobServer() |
Configuration |
getConfiguration() |
FatalErrorHandler |
getFatalErrorHandler() |
HeartbeatServices |
getHeartbeatServices() |
HighAvailabilityServices |
getHighAvailabilityServices() |
HistoryServerArchivist |
getHistoryServerArchivist() |
Executor |
getIoExecutor() |
JobGraphWriter |
getJobGraphWriter() |
JobManagerMetricGroup |
getJobManagerMetricGroup() |
JobResultStore |
getJobResultStore() |
String |
getMetricQueryServiceAddress() |
DispatcherOperationCaches |
getOperationCaches() |
GatewayRetriever<ResourceManagerGateway> |
getResourceManagerGatewayRetriever() |
public Configuration getConfiguration()
public HighAvailabilityServices getHighAvailabilityServices()
public GatewayRetriever<ResourceManagerGateway> getResourceManagerGatewayRetriever()
public BlobServer getBlobServer()
public HeartbeatServices getHeartbeatServices()
public JobManagerMetricGroup getJobManagerMetricGroup()
public ExecutionGraphInfoStore getArchivedExecutionGraphStore()
public FatalErrorHandler getFatalErrorHandler()
public HistoryServerArchivist getHistoryServerArchivist()
public DispatcherOperationCaches getOperationCaches()
public JobGraphWriter getJobGraphWriter()
public JobResultStore getJobResultStore()
public Executor getIoExecutor()
public static DispatcherServices from(PartialDispatcherServicesWithJobPersistenceComponents partialDispatcherServicesWithJobPersistenceComponents, JobManagerRunnerFactory jobManagerRunnerFactory, CleanupRunnerFactory cleanupRunnerFactory)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.