org.apache.flink.runtime.dispatcher.runner

Class DefaultDispatcherRunnerFactory

java.lang.Object

org.apache.flink.runtime.dispatcher.runner.DefaultDispatcherRunnerFactory

All Implemented Interfaces:

DispatcherRunnerFactory

public class DefaultDispatcherRunnerFactory
extends Object
implements DispatcherRunnerFactory

DispatcherRunnerFactory implementation which creates DefaultDispatcherRunner instances.

Constructor Summary

Constructors

Constructor and Description
DefaultDispatcherRunnerFactory(DispatcherLeaderProcessFactoryFactory dispatcherLeaderProcessFactoryFactory)

Method Summary

Modifier and Type	Method and Description
DispatcherRunner	createDispatcherRunner(LeaderElectionService leaderElectionService, FatalErrorHandler fatalErrorHandler, JobPersistenceComponentFactory jobPersistenceComponentFactory, Executor ioExecutor, RpcService rpcService, PartialDispatcherServices partialDispatcherServices)
static DefaultDispatcherRunnerFactory	createJobRunner(JobGraphRetriever jobGraphRetriever)
static DefaultDispatcherRunnerFactory	createSessionRunner(DispatcherFactory dispatcherFactory)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultDispatcherRunnerFactory

public DefaultDispatcherRunnerFactory(DispatcherLeaderProcessFactoryFactory dispatcherLeaderProcessFactoryFactory)

Method Detail

createDispatcherRunner

public DispatcherRunner createDispatcherRunner(LeaderElectionService leaderElectionService,
                                               FatalErrorHandler fatalErrorHandler,
                                               JobPersistenceComponentFactory jobPersistenceComponentFactory,
                                               Executor ioExecutor,
                                               RpcService rpcService,
                                               PartialDispatcherServices partialDispatcherServices)
                                        throws Exception

Specified by:

createDispatcherRunner in interface DispatcherRunnerFactory

Throws:

Exception

createSessionRunner

public static DefaultDispatcherRunnerFactory createSessionRunner(DispatcherFactory dispatcherFactory)

createJobRunner

public static DefaultDispatcherRunnerFactory createJobRunner(JobGraphRetriever jobGraphRetriever)