Modifier and Type | Method and Description |
---|---|
List<JobID> |
ApplicationRunner.run(DispatcherGateway dispatcherGateway,
PackagedProgram program,
Configuration configuration)
Runs the application using the provided
dispatcherGateway . |
List<JobID> |
DetachedApplicationRunner.run(DispatcherGateway dispatcherGateway,
PackagedProgram program,
Configuration configuration) |
Constructor and Description |
---|
ApplicationDispatcherBootstrap(PackagedProgram application,
Collection<JobID> recoveredJobIds,
Configuration configuration,
DispatcherGateway dispatcherGateway,
ScheduledExecutor scheduledExecutor,
FatalErrorHandler errorHandler) |
EmbeddedJobClient(JobID jobId,
DispatcherGateway dispatcherGateway,
ScheduledExecutor retryExecutor,
Time rpcTimeout,
ClassLoader classLoader) |
Constructor and Description |
---|
EmbeddedExecutor(Collection<JobID> submittedJobIds,
DispatcherGateway dispatcherGateway,
EmbeddedJobClientCreator jobClientCreator)
Creates a
EmbeddedExecutor . |
EmbeddedExecutorFactory(Collection<JobID> submittedJobIds,
DispatcherGateway dispatcherGateway,
ScheduledExecutor retryExecutor)
Creates an
EmbeddedExecutorFactory . |
EmbeddedExecutorServiceLoader(Collection<JobID> submittedJobIds,
DispatcherGateway dispatcherGateway,
ScheduledExecutor retryExecutor)
Creates an
EmbeddedExecutorServiceLoader . |
WebSubmissionExecutorFactory(Collection<JobID> submittedJobIds,
DispatcherGateway dispatcherGateway)
Creates an
WebSubmissionExecutorFactory . |
WebSubmissionExecutorServiceLoader(Collection<JobID> submittedJobIds,
DispatcherGateway dispatcherGateway)
Creates an
WebSubmissionExecutorServiceLoader . |
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
|
Modifier and Type | Method and Description |
---|---|
DispatcherBootstrap |
DispatcherBootstrapFactory.create(DispatcherGateway dispatcher,
ScheduledExecutor scheduledExecutor,
FatalErrorHandler errorHandler) |
Constructor and Description |
---|
DispatcherRestEndpoint(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 |
---|---|
DispatcherGateway |
DefaultDispatcherGatewayService.getGateway() |
DispatcherGateway |
AbstractDispatcherLeaderProcess.DispatcherGatewayService.getGateway() |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<DispatcherGateway> |
StoppedDispatcherLeaderProcess.getDispatcherGateway() |
CompletableFuture<DispatcherGateway> |
AbstractDispatcherLeaderProcess.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> 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 |
---|---|
CompletableFuture<JarRunResponseBody> |
JarRunHandler.handleRequest(HandlerRequest<JarRunRequestBody> 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,
java.util.function.Supplier<ApplicationRunner> applicationRunnerSupplier) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.