org.apache.flink.client.deployment.application

Class ApplicationDispatcherLeaderProcessFactoryFactory

java.lang.Object

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

All Implemented Interfaces:

DispatcherLeaderProcessFactoryFactory

@Internal
public class ApplicationDispatcherLeaderProcessFactoryFactory
extends Object
implements DispatcherLeaderProcessFactoryFactory

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

Method Summary

Modifier and Type	Method and Description
static ApplicationDispatcherLeaderProcessFactoryFactory	create(Configuration configuration, DispatcherFactory dispatcherFactory, PackagedProgram program)
DispatcherLeaderProcessFactory	createFactory(JobPersistenceComponentFactory jobPersistenceComponentFactory, Executor ioExecutor, RpcService rpcService, PartialDispatcherServices partialDispatcherServices, FatalErrorHandler fatalErrorHandler)

Methods inherited from class java.lang.Object

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

Method Detail

createFactory

public DispatcherLeaderProcessFactory createFactory(JobPersistenceComponentFactory jobPersistenceComponentFactory,
                                                    Executor ioExecutor,
                                                    RpcService rpcService,
                                                    PartialDispatcherServices partialDispatcherServices,
                                                    FatalErrorHandler fatalErrorHandler)

Specified by:

createFactory in interface DispatcherLeaderProcessFactoryFactory

create

public static ApplicationDispatcherLeaderProcessFactoryFactory create(Configuration configuration,
                                                                      DispatcherFactory dispatcherFactory,
                                                                      PackagedProgram program)