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

Class ApplicationDispatcherLeaderProcessFactoryFactory

java.lang.Object

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

All Implemented Interfaces:

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.

Method Summary

Modifier and Type	Method	Description
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.JobPersistenceComponentFactory jobPersistenceComponentFactory, Executor ioExecutor, org.apache.flink.runtime.rpc.RpcService rpcService, org.apache.flink.runtime.dispatcher.PartialDispatcherServices partialDispatcherServices, org.apache.flink.runtime.rpc.FatalErrorHandler fatalErrorHandler)

Methods inherited from class java.lang.Object

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

Method Detail

createFactory

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

Specified by:

createFactory in interface 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)