public class DefaultDispatcherRunnerFactory extends Object implements DispatcherRunnerFactory
DispatcherRunnerFactory
implementation which creates DefaultDispatcherRunner
instances.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 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–2020 The Apache Software Foundation. All rights reserved.