Modifier and Type | Class and Description |
---|---|
class |
Dispatcher
Base class for the Dispatcher component.
|
class |
StandaloneDispatcher
|
Constructor and Description |
---|
DispatcherRestEndpoint(RestServerEndpointConfiguration endpointConfiguration,
GatewayRetriever<DispatcherGateway> leaderRetriever,
Configuration clusterConfiguration,
RestHandlerConfiguration restConfiguration,
Executor executor) |
Modifier and Type | Method and Description |
---|---|
protected DispatcherRestEndpoint |
SessionClusterEntrypoint.createDispatcherRestEndpoint(Configuration configuration,
LeaderGatewayRetriever<DispatcherGateway> dispatcherGatewayRetriever,
Executor executor) |
Modifier and Type | Method and Description |
---|---|
protected CompletableFuture<BlobServerPortResponseBody> |
BlobServerPortHandler.handleRequest(HandlerRequest<EmptyRequestBody,EmptyMessageParameters> request,
DispatcherGateway gateway) |
CompletableFuture<EmptyResponseBody> |
JobTerminationHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobTerminationMessageParameters> request,
DispatcherGateway gateway) |
protected CompletableFuture<JobSubmitResponseBody> |
JobSubmitHandler.handleRequest(HandlerRequest<JobSubmitRequestBody,EmptyMessageParameters> request,
DispatcherGateway gateway) |
Constructor and Description |
---|
BlobServerPortHandler(CompletableFuture<String> localRestAddress,
GatewayRetriever<DispatcherGateway> leaderRetriever,
Time timeout) |
JobSubmitHandler(CompletableFuture<String> localRestAddress,
GatewayRetriever<DispatcherGateway> leaderRetriever,
Time timeout) |
JobTerminationHandler(CompletableFuture<String> localRestAddress,
GatewayRetriever<DispatcherGateway> leaderRetriever,
Time timeout,
MessageHeaders<EmptyRequestBody,EmptyResponseBody,JobTerminationMessageParameters> messageHeaders) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<DashboardConfiguration> |
DashboardConfigHandler.handleRequest(HandlerRequest<EmptyRequestBody,EmptyMessageParameters> request,
DispatcherGateway gateway) |
CompletableFuture<ClusterConfigurationInfo> |
ClusterConfigHandler.handleRequest(HandlerRequest<EmptyRequestBody,EmptyMessageParameters> request,
DispatcherGateway gateway) |
CompletableFuture<MultipleJobsDetails> |
CurrentJobsOverviewHandler.handleRequest(HandlerRequest<EmptyRequestBody,EmptyMessageParameters> request,
DispatcherGateway gateway) |
CompletableFuture<ClusterOverviewWithVersion> |
ClusterOverviewHandler.handleRequest(HandlerRequest<EmptyRequestBody,EmptyMessageParameters> request,
DispatcherGateway gateway) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.