Modifier and Type | Method and Description |
---|---|
GatewayRetriever<ResourceManagerGateway> |
DispatcherServices.getResourceManagerGatewayRetriever() |
GatewayRetriever<ResourceManagerGateway> |
PartialDispatcherServices.getResourceManagerGatewayRetriever() |
Constructor and Description |
---|
DispatcherRestEndpoint(RestServerEndpointConfiguration endpointConfiguration,
GatewayRetriever<DispatcherGateway> leaderRetriever,
Configuration clusterConfiguration,
RestHandlerConfiguration restConfiguration,
GatewayRetriever<ResourceManagerGateway> resourceManagerRetriever,
TransientBlobService transientBlobService,
ScheduledExecutorService executor,
MetricFetcher metricFetcher,
LeaderElectionService leaderElectionService,
ExecutionGraphCache executionGraphCache,
FatalErrorHandler fatalErrorHandler) |
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) |
PartialDispatcherServices(Configuration configuration,
HighAvailabilityServices highAvailabilityServices,
GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever,
BlobServer blobServer,
HeartbeatServices heartbeatServices,
JobManagerMetricGroupFactory jobManagerMetricGroupFactory,
ArchivedExecutionGraphStore archivedExecutionGraphStore,
FatalErrorHandler fatalErrorHandler,
HistoryServerArchivist historyServerArchivist,
String metricQueryServiceAddress,
Executor ioExecutor) |
PartialDispatcherServicesWithJobGraphStore(Configuration configuration,
HighAvailabilityServices highAvailabilityServices,
GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever,
BlobServer blobServer,
HeartbeatServices heartbeatServices,
JobManagerMetricGroupFactory jobManagerMetricGroupFactory,
ArchivedExecutionGraphStore archivedExecutionGraphStore,
FatalErrorHandler fatalErrorHandler,
HistoryServerArchivist historyServerArchivist,
String metricQueryServiceAddress,
Executor ioExecutor,
JobGraphWriter jobGraphWriter) |
Modifier and Type | Method and Description |
---|---|
ResourceManagerGateway |
DefaultResourceManagerService.getGateway() |
Constructor and Description |
---|
MiniDispatcherRestEndpoint(RestServerEndpointConfiguration endpointConfiguration,
GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Configuration clusterConfiguration,
RestHandlerConfiguration restConfiguration,
GatewayRetriever<ResourceManagerGateway> resourceManagerRetriever,
TransientBlobService transientBlobService,
ScheduledExecutorService executor,
MetricFetcher metricFetcher,
LeaderElectionService leaderElectionService,
ExecutionGraphCache executionGraphCache,
FatalErrorHandler fatalErrorHandler) |
Modifier and Type | Method and Description |
---|---|
void |
SlotPool.connectToResourceManager(ResourceManagerGateway resourceManagerGateway)
Connects the SlotPool to the given ResourceManager.
|
void |
SlotPoolImpl.connectToResourceManager(ResourceManagerGateway resourceManagerGateway) |
Modifier and Type | Class and Description |
---|---|
class |
ResourceManager<WorkerType extends ResourceIDRetrievable>
ResourceManager implementation.
|
class |
StandaloneResourceManager
A standalone implementation of the resource manager.
|
Modifier and Type | Class and Description |
---|---|
class |
ActiveResourceManager<WorkerType extends ResourceIDRetrievable>
An active implementation of
ResourceManager . |
Modifier and Type | Method and Description |
---|---|
protected CompletableFuture<ClusterDataSetListResponseBody> |
ClusterDataSetListHandler.handleRequest(HandlerRequest<EmptyRequestBody,EmptyMessageParameters> request,
ResourceManagerGateway gateway) |
Constructor and Description |
---|
ClusterDataSetDeleteTriggerHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever) |
ClusterDataSetListHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever) |
Modifier and Type | Method and Description |
---|---|
static ResourceManagerGateway |
AbstractResourceManagerHandler.getResourceManagerGateway(GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever) |
Modifier and Type | Method and Description |
---|---|
protected abstract CompletableFuture<P> |
AbstractResourceManagerHandler.handleRequest(HandlerRequest<R,M> request,
ResourceManagerGateway gateway) |
Modifier and Type | Method and Description |
---|---|
static ResourceManagerGateway |
AbstractResourceManagerHandler.getResourceManagerGateway(GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever) |
Constructor and Description |
---|
AbstractResourceManagerHandler(GatewayRetriever<? extends T> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
MessageHeaders<R,P,M> messageHeaders,
GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever) |
Modifier and Type | Method and Description |
---|---|
protected RetryingRegistration<ResourceManagerId,ResourceManagerGateway,TaskExecutorRegistrationSuccess,TaskExecutorRegistrationRejection> |
TaskExecutorToResourceManagerConnection.generateRegistration() |
Constructor and Description |
---|
WebMonitorEndpoint(RestServerEndpointConfiguration endpointConfiguration,
GatewayRetriever<? extends T> leaderRetriever,
Configuration clusterConfiguration,
RestHandlerConfiguration restConfiguration,
GatewayRetriever<ResourceManagerGateway> resourceManagerRetriever,
TransientBlobService transientBlobService,
ScheduledExecutorService executor,
MetricFetcher metricFetcher,
LeaderElectionService leaderElectionService,
ExecutionGraphCache executionGraphCache,
FatalErrorHandler fatalErrorHandler) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.