org.apache.flink.client.deployment.application

类 ApplicationDispatcherLeaderProcessFactoryFactory

java.lang.Object

org.apache.flink.client.deployment.application.ApplicationDispatcherLeaderProcessFactoryFactory

所有已实现的接口:

org.apache.flink.runtime.dispatcher.runner.DispatcherLeaderProcessFactoryFactory

@Internal
public class ApplicationDispatcherLeaderProcessFactoryFactory
extends Object
implements org.apache.flink.runtime.dispatcher.runner.DispatcherLeaderProcessFactoryFactory

Factory for a DispatcherLeaderProcessFactoryFactory designed to be used when executing an application in Application Mode.

方法概要

限定符和类型	方法和说明
static ApplicationDispatcherLeaderProcessFactoryFactory	create(org.apache.flink.configuration.Configuration configuration, org.apache.flink.runtime.dispatcher.DispatcherFactory dispatcherFactory, PackagedProgram program)
org.apache.flink.runtime.dispatcher.runner.DispatcherLeaderProcessFactory	createFactory(org.apache.flink.runtime.jobmanager.JobGraphStoreFactory jobGraphStoreFactory, Executor ioExecutor, org.apache.flink.runtime.rpc.RpcService rpcService, org.apache.flink.runtime.dispatcher.PartialDispatcherServices partialDispatcherServices, org.apache.flink.runtime.rpc.FatalErrorHandler fatalErrorHandler)

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

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

方法详细资料

createFactory

public org.apache.flink.runtime.dispatcher.runner.DispatcherLeaderProcessFactory createFactory(org.apache.flink.runtime.jobmanager.JobGraphStoreFactory jobGraphStoreFactory,
                                                                                               Executor ioExecutor,
                                                                                               org.apache.flink.runtime.rpc.RpcService rpcService,
                                                                                               org.apache.flink.runtime.dispatcher.PartialDispatcherServices partialDispatcherServices,
                                                                                               org.apache.flink.runtime.rpc.FatalErrorHandler fatalErrorHandler)

指定者:

createFactory 在接口中 org.apache.flink.runtime.dispatcher.runner.DispatcherLeaderProcessFactoryFactory

create

public static ApplicationDispatcherLeaderProcessFactoryFactory create(org.apache.flink.configuration.Configuration configuration,
                                                                      org.apache.flink.runtime.dispatcher.DispatcherFactory dispatcherFactory,
                                                                      PackagedProgram program)