Package org.apache.flink.client.deployment.application

Class ApplicationDispatcherGatewayServiceFactory

java.lang.Object

org.apache.flink.client.deployment.application.ApplicationDispatcherGatewayServiceFactory

All Implemented Interfaces:

AbstractDispatcherLeaderProcess.DispatcherGatewayServiceFactory

@Internal
public class ApplicationDispatcherGatewayServiceFactory
extends Object
implements AbstractDispatcherLeaderProcess.DispatcherGatewayServiceFactory

A DispatcherGatewayServiceFactory used when executing a job in Application Mode, i.e. the user's main is executed on the same machine as the Dispatcher and the lifecycle of the cluster is the same as the one of the application.

It instantiates a DispatcherGatewayService with an ApplicationDispatcherBootstrap containing the user's program.

Constructor Summary

Constructors

Constructor	Description
ApplicationDispatcherGatewayServiceFactory(Configuration configuration, DispatcherFactory dispatcherFactory, PackagedProgram application, RpcService rpcService, PartialDispatcherServices partialDispatcherServices)

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ApplicationDispatcherGatewayServiceFactory

public ApplicationDispatcherGatewayServiceFactory(Configuration configuration,
                                                  DispatcherFactory dispatcherFactory,
                                                  PackagedProgram application,
                                                  RpcService rpcService,
                                                  PartialDispatcherServices partialDispatcherServices)

Method Detail

create

public AbstractDispatcherLeaderProcess.DispatcherGatewayService create(DispatcherId fencingToken,
                                                                       Collection<ExecutionPlan> recoveredJobs,
                                                                       Collection<JobResult> recoveredDirtyJobResults,
                                                                       ExecutionPlanWriter executionPlanWriter,
                                                                       JobResultStore jobResultStore)

Specified by:

create in interface AbstractDispatcherLeaderProcess.DispatcherGatewayServiceFactory