org.apache.flink.client.deployment.application

类 ApplicationDispatcherGatewayServiceFactory

java.lang.Object

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

所有已实现的接口:

org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess.DispatcherGatewayServiceFactory

@Internal
public class ApplicationDispatcherGatewayServiceFactory
extends Object
implements org.apache.flink.runtime.dispatcher.runner.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.

构造器概要

构造器

构造器和说明
ApplicationDispatcherGatewayServiceFactory(org.apache.flink.configuration.Configuration configuration, org.apache.flink.runtime.dispatcher.DispatcherFactory dispatcherFactory, PackagedProgram application, org.apache.flink.runtime.rpc.RpcService rpcService, org.apache.flink.runtime.dispatcher.PartialDispatcherServices partialDispatcherServices)

方法概要

限定符和类型	方法和说明
org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess.DispatcherGatewayService	create(org.apache.flink.runtime.dispatcher.DispatcherId fencingToken, Collection<org.apache.flink.runtime.jobgraph.JobGraph> recoveredJobs, org.apache.flink.runtime.jobmanager.JobGraphWriter jobGraphWriter)

从类继承的方法 java.lang.Object

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

构造器详细资料

ApplicationDispatcherGatewayServiceFactory

public ApplicationDispatcherGatewayServiceFactory(org.apache.flink.configuration.Configuration configuration,
                                                  org.apache.flink.runtime.dispatcher.DispatcherFactory dispatcherFactory,
                                                  PackagedProgram application,
                                                  org.apache.flink.runtime.rpc.RpcService rpcService,
                                                  org.apache.flink.runtime.dispatcher.PartialDispatcherServices partialDispatcherServices)

方法详细资料

create

public org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess.DispatcherGatewayService create(org.apache.flink.runtime.dispatcher.DispatcherId fencingToken,
                                                                                                                  Collection<org.apache.flink.runtime.jobgraph.JobGraph> recoveredJobs,
                                                                                                                  org.apache.flink.runtime.jobmanager.JobGraphWriter jobGraphWriter)

指定者:

create 在接口中 org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess.DispatcherGatewayServiceFactory