Uses of Interface
org.apache.flink.runtime.dispatcher.DispatcherGateway

Packages that use DispatcherGateway

Package	Description
org.apache.flink.client.deployment.application
org.apache.flink.client.deployment.application.executors
org.apache.flink.runtime.dispatcher
org.apache.flink.runtime.dispatcher.runner
org.apache.flink.runtime.minicluster
org.apache.flink.runtime.rest
org.apache.flink.runtime.rest.handler.job
org.apache.flink.runtime.webmonitor
org.apache.flink.runtime.webmonitor.handlers

Uses of DispatcherGateway in org.apache.flink.client.deployment.application

Methods in org.apache.flink.client.deployment.application with parameters of type DispatcherGateway

Modifier and Type	Method	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)

Constructors in org.apache.flink.client.deployment.application with parameters of type DispatcherGateway

Constructor	Description
ApplicationDispatcherBootstrap(PackagedProgram application, Collection<JobID> recoveredJobIds, Configuration configuration, DispatcherGateway dispatcherGateway, ScheduledExecutor scheduledExecutor, FatalErrorHandler errorHandler)
EmbeddedJobClient(JobID jobId, DispatcherGateway dispatcherGateway, ScheduledExecutor retryExecutor, Duration rpcTimeout, ClassLoader classLoader)

Uses of DispatcherGateway in org.apache.flink.client.deployment.application.executors

Constructors in org.apache.flink.client.deployment.application.executors with parameters of type DispatcherGateway

Constructor	Description
EmbeddedExecutor(Collection<JobID> submittedJobIds, DispatcherGateway dispatcherGateway, Configuration configuration, 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.

Uses of DispatcherGateway in org.apache.flink.runtime.dispatcher

Classes in org.apache.flink.runtime.dispatcher that implement DispatcherGateway

Modifier and Type	Class	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	Dispatcher implementation which spawns a JobMaster for each submitted JobGraph within in the same process.

Methods in org.apache.flink.runtime.dispatcher with parameters of type DispatcherGateway

Modifier and Type	Method	Description
DispatcherBootstrap	DispatcherBootstrapFactory.create(DispatcherGateway dispatcher, ScheduledExecutor scheduledExecutor, FatalErrorHandler errorHandler)

Constructor parameters in org.apache.flink.runtime.dispatcher with type arguments of type DispatcherGateway

Constructor

Description

DispatcherRestEndpoint(GatewayRetriever<DispatcherGateway> leaderRetriever, Configuration clusterConfiguration, RestHandlerConfiguration restConfiguration, GatewayRetriever<ResourceManagerGateway> resourceManagerRetriever, TransientBlobService transientBlobService, ScheduledExecutorService executor, MetricFetcher metricFetcher, LeaderElection leaderElection, ExecutionGraphCache executionGraphCache, FatalErrorHandler fatalErrorHandler)

Uses of DispatcherGateway in org.apache.flink.runtime.dispatcher.runner

Methods in org.apache.flink.runtime.dispatcher.runner that return DispatcherGateway

Modifier and Type	Method	Description
DispatcherGateway	AbstractDispatcherLeaderProcess.DispatcherGatewayService.getGateway()
DispatcherGateway	DefaultDispatcherGatewayService.getGateway()

Methods in org.apache.flink.runtime.dispatcher.runner that return types with arguments of type DispatcherGateway

Modifier and Type	Method	Description
CompletableFuture<DispatcherGateway>	AbstractDispatcherLeaderProcess.getDispatcherGateway()
CompletableFuture<DispatcherGateway>	StoppedDispatcherLeaderProcess.getDispatcherGateway()

Uses of DispatcherGateway in org.apache.flink.runtime.minicluster

Methods in org.apache.flink.runtime.minicluster that return types with arguments of type DispatcherGateway

Modifier and Type	Method	Description
protected CompletableFuture<DispatcherGateway>	MiniCluster.getDispatcherGatewayFuture()

Uses of DispatcherGateway in org.apache.flink.runtime.rest

Methods in org.apache.flink.runtime.rest that return types with arguments of type DispatcherGateway

Modifier and Type	Method	Description
WebMonitorEndpoint<DispatcherGateway>	SessionRestEndpointFactory.createRestEndpoint(Configuration configuration, LeaderGatewayRetriever<DispatcherGateway> dispatcherGatewayRetriever, LeaderGatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, TransientBlobService transientBlobService, ScheduledExecutorService executor, MetricFetcher metricFetcher, LeaderElection leaderElection, FatalErrorHandler fatalErrorHandler)

Method parameters in org.apache.flink.runtime.rest with type arguments of type DispatcherGateway

Modifier and Type	Method	Description
WebMonitorEndpoint<RestfulGateway>	JobRestEndpointFactory.createRestEndpoint(Configuration configuration, LeaderGatewayRetriever<DispatcherGateway> dispatcherGatewayRetriever, LeaderGatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, TransientBlobService transientBlobService, ScheduledExecutorService executor, MetricFetcher metricFetcher, LeaderElection leaderElection, FatalErrorHandler fatalErrorHandler)
WebMonitorEndpoint<T>	RestEndpointFactory.createRestEndpoint(Configuration configuration, LeaderGatewayRetriever<DispatcherGateway> dispatcherGatewayRetriever, LeaderGatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, TransientBlobService transientBlobService, ScheduledExecutorService executor, MetricFetcher metricFetcher, LeaderElection leaderElection, FatalErrorHandler fatalErrorHandler)
WebMonitorEndpoint<DispatcherGateway>	SessionRestEndpointFactory.createRestEndpoint(Configuration configuration, LeaderGatewayRetriever<DispatcherGateway> dispatcherGatewayRetriever, LeaderGatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, TransientBlobService transientBlobService, ScheduledExecutorService executor, MetricFetcher metricFetcher, LeaderElection leaderElection, FatalErrorHandler fatalErrorHandler)

Uses of DispatcherGateway in org.apache.flink.runtime.rest.handler.job

Methods in org.apache.flink.runtime.rest.handler.job with parameters of type DispatcherGateway

Modifier and Type	Method	Description
protected CompletableFuture<JobSubmitResponseBody>	JobSubmitHandler.handleRequest(HandlerRequest<JobSubmitRequestBody> request, DispatcherGateway gateway)

Constructor parameters in org.apache.flink.runtime.rest.handler.job with type arguments of type DispatcherGateway

Constructor	Description
JobSubmitHandler(GatewayRetriever<? extends DispatcherGateway> leaderRetriever, Duration timeout, Map<String,String> headers, Executor executor, Configuration configuration)

Uses of DispatcherGateway in org.apache.flink.runtime.webmonitor

Method parameters in org.apache.flink.runtime.webmonitor with type arguments of type DispatcherGateway

Modifier and Type	Method	Description
static WebMonitorExtension	WebMonitorUtils.loadWebSubmissionExtension(GatewayRetriever<? extends DispatcherGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, CompletableFuture<String> localAddressFuture, Path uploadDir, Executor executor, Configuration configuration)	Loads the WebMonitorExtension which enables web submission.

Constructor parameters in org.apache.flink.runtime.webmonitor with type arguments of type DispatcherGateway

Constructor	Description
WebSubmissionExtension(Configuration configuration, GatewayRetriever<? extends DispatcherGateway> leaderRetriever, Map<String,String> responseHeaders, CompletableFuture<String> localAddressFuture, Path jarDir, Executor executor, Duration timeout)

Uses of DispatcherGateway in org.apache.flink.runtime.webmonitor.handlers

Methods in org.apache.flink.runtime.webmonitor.handlers with parameters of type DispatcherGateway

Modifier and Type	Method	Description
CompletableFuture<JarRunResponseBody>	JarRunHandler.handleRequest(HandlerRequest<JarRunRequestBody> request, DispatcherGateway gateway)

Constructor parameters in org.apache.flink.runtime.webmonitor.handlers with type arguments of type DispatcherGateway

Constructor	Description
JarRunHandler(GatewayRetriever<? extends DispatcherGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<JarRunRequestBody,JarRunResponseBody,JarRunMessageParameters> messageHeaders, Path jarDir, Configuration configuration, Executor executor, Supplier<ApplicationRunner> applicationRunnerSupplier)