Uses of Interface
org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess.DispatcherGatewayService

Packages that use AbstractDispatcherLeaderProcess.DispatcherGatewayService

Package	Description
org.apache.flink.client.deployment.application
org.apache.flink.runtime.dispatcher.runner

Uses of AbstractDispatcherLeaderProcess.DispatcherGatewayService in org.apache.flink.client.deployment.application

Methods in org.apache.flink.client.deployment.application that return AbstractDispatcherLeaderProcess.DispatcherGatewayService

Modifier and Type	Method	Description
AbstractDispatcherLeaderProcess.DispatcherGatewayService	ApplicationDispatcherGatewayServiceFactory.create(DispatcherId fencingToken, Collection<ExecutionPlan> recoveredJobs, Collection<JobResult> recoveredDirtyJobResults, ExecutionPlanWriter executionPlanWriter, JobResultStore jobResultStore)

Uses of AbstractDispatcherLeaderProcess.DispatcherGatewayService in org.apache.flink.runtime.dispatcher.runner

Classes in org.apache.flink.runtime.dispatcher.runner that implement AbstractDispatcherLeaderProcess.DispatcherGatewayService

Modifier and Type	Class	Description
class	DefaultDispatcherGatewayService	A facade over the Dispatcher that exposes specific functionality.

Methods in org.apache.flink.runtime.dispatcher.runner that return AbstractDispatcherLeaderProcess.DispatcherGatewayService

Modifier and Type	Method	Description
AbstractDispatcherLeaderProcess.DispatcherGatewayService	AbstractDispatcherLeaderProcess.DispatcherGatewayServiceFactory.create(DispatcherId dispatcherId, Collection<ExecutionPlan> recoveredJobs, Collection<JobResult> recoveredDirtyJobResults, ExecutionPlanWriter executionPlanWriter, JobResultStore jobResultStore)

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

Modifier and Type	Method	Description
protected Optional<AbstractDispatcherLeaderProcess.DispatcherGatewayService>	AbstractDispatcherLeaderProcess.getDispatcherService()