Modifier and Type | Class and Description |
---|---|
class |
Dispatcher
Base class for the Dispatcher component.
|
class |
MiniDispatcher
Mini Dispatcher which is instantiated as the dispatcher component by the
JobClusterEntrypoint . |
class |
StandaloneDispatcher
|
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) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<DispatcherGateway> |
StoppedDispatcherLeaderProcess.getDispatcherGateway() |
Modifier and Type | Method and Description |
---|---|
protected CompletableFuture<DispatcherGateway> |
MiniCluster.getDispatcherGatewayFuture() |
Modifier and Type | Method and Description |
---|---|
WebMonitorEndpoint<DispatcherGateway> |
SessionRestEndpointFactory.createRestEndpoint(Configuration configuration,
LeaderGatewayRetriever<DispatcherGateway> dispatcherGatewayRetriever,
LeaderGatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever,
TransientBlobService transientBlobService,
ScheduledExecutorService executor,
MetricFetcher metricFetcher,
LeaderElectionService leaderElectionService,
FatalErrorHandler fatalErrorHandler) |
Modifier and Type | Method and Description |
---|---|
protected CompletableFuture<JobSubmitResponseBody> |
JobSubmitHandler.handleRequest(HandlerRequest<JobSubmitRequestBody,EmptyMessageParameters> request,
DispatcherGateway gateway) |
Constructor and Description |
---|
JobSubmitHandler(GatewayRetriever<? extends DispatcherGateway> leaderRetriever,
Time timeout,
Map<String,String> headers,
Executor executor,
Configuration configuration) |
Modifier and Type | Method and Description |
---|---|
static WebMonitorExtension |
WebMonitorUtils.loadWebSubmissionExtension(GatewayRetriever<? extends DispatcherGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
CompletableFuture<String> localAddressFuture,
Path uploadDir,
Executor executor,
Configuration configuration)
Loads the
WebMonitorExtension which enables web submission. |
Constructor and Description |
---|
WebSubmissionExtension(Configuration configuration,
GatewayRetriever<? extends DispatcherGateway> leaderRetriever,
Map<String,String> responseHeaders,
CompletableFuture<String> localAddressFuture,
Path jarDir,
Executor executor,
Time timeout) |
Modifier and Type | Method and Description |
---|---|
protected CompletableFuture<JarRunResponseBody> |
JarRunHandler.handleRequest(HandlerRequest<JarRunRequestBody,JarRunMessageParameters> request,
DispatcherGateway gateway) |
Constructor and Description |
---|
JarRunHandler(GatewayRetriever<? extends DispatcherGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
MessageHeaders<JarRunRequestBody,JarRunResponseBody,JarRunMessageParameters> messageHeaders,
Path jarDir,
Configuration configuration,
Executor executor) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.