public class DefaultDispatcherRunnerFactory extends Object implements DispatcherRunnerFactory
DispatcherRunnerFactory
implementation which creates DefaultDispatcherRunner
instances.Constructor and Description |
---|
DefaultDispatcherRunnerFactory(DispatcherLeaderProcessFactoryFactory dispatcherLeaderProcessFactoryFactory) |
Modifier and Type | Method and Description |
---|---|
DispatcherRunner |
createDispatcherRunner(LeaderElectionService leaderElectionService,
FatalErrorHandler fatalErrorHandler,
JobGraphStoreFactory jobGraphStoreFactory,
Executor ioExecutor,
RpcService rpcService,
PartialDispatcherServices partialDispatcherServices) |
static DefaultDispatcherRunnerFactory |
createJobRunner(JobGraphRetriever jobGraphRetriever) |
static DefaultDispatcherRunnerFactory |
createSessionRunner(DispatcherFactory dispatcherFactory) |
public DefaultDispatcherRunnerFactory(DispatcherLeaderProcessFactoryFactory dispatcherLeaderProcessFactoryFactory)
public DispatcherRunner createDispatcherRunner(LeaderElectionService leaderElectionService, FatalErrorHandler fatalErrorHandler, JobGraphStoreFactory jobGraphStoreFactory, Executor ioExecutor, RpcService rpcService, PartialDispatcherServices partialDispatcherServices) throws Exception
createDispatcherRunner
in interface DispatcherRunnerFactory
Exception
public static DefaultDispatcherRunnerFactory createSessionRunner(DispatcherFactory dispatcherFactory)
public static DefaultDispatcherRunnerFactory createJobRunner(JobGraphRetriever jobGraphRetriever)
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.