public class PartialDispatcherServicesWithJobGraphStore extends PartialDispatcherServices
DispatcherFactory
services container.Constructor and Description |
---|
PartialDispatcherServicesWithJobGraphStore(Configuration configuration,
HighAvailabilityServices highAvailabilityServices,
GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever,
BlobServer blobServer,
HeartbeatServices heartbeatServices,
JobManagerMetricGroupFactory jobManagerMetricGroupFactory,
ExecutionGraphInfoStore executionGraphInfoStore,
FatalErrorHandler fatalErrorHandler,
HistoryServerArchivist historyServerArchivist,
String metricQueryServiceAddress,
Executor ioExecutor,
JobGraphWriter jobGraphWriter) |
Modifier and Type | Method and Description |
---|---|
static PartialDispatcherServicesWithJobGraphStore |
from(PartialDispatcherServices partialDispatcherServices,
JobGraphWriter jobGraphWriter) |
JobGraphWriter |
getJobGraphWriter() |
getArchivedExecutionGraphStore, getBlobServer, getConfiguration, getFatalErrorHandler, getHeartbeatServices, getHighAvailabilityServices, getHistoryServerArchivist, getIoExecutor, getJobManagerMetricGroupFactory, getMetricQueryServiceAddress, getResourceManagerGatewayRetriever
public PartialDispatcherServicesWithJobGraphStore(@Nonnull Configuration configuration, @Nonnull HighAvailabilityServices highAvailabilityServices, @Nonnull GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, @Nonnull BlobServer blobServer, @Nonnull HeartbeatServices heartbeatServices, @Nonnull JobManagerMetricGroupFactory jobManagerMetricGroupFactory, @Nonnull ExecutionGraphInfoStore executionGraphInfoStore, @Nonnull FatalErrorHandler fatalErrorHandler, @Nonnull HistoryServerArchivist historyServerArchivist, @Nullable String metricQueryServiceAddress, @Nonnull Executor ioExecutor, @Nonnull JobGraphWriter jobGraphWriter)
@Nonnull public JobGraphWriter getJobGraphWriter()
public static PartialDispatcherServicesWithJobGraphStore from(PartialDispatcherServices partialDispatcherServices, JobGraphWriter jobGraphWriter)
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.