Package | Description |
---|---|
org.apache.flink.client.deployment.application | |
org.apache.flink.runtime.dispatcher | |
org.apache.flink.runtime.dispatcher.runner |
Modifier and Type | Method and Description |
---|---|
DispatcherLeaderProcessFactory |
ApplicationDispatcherLeaderProcessFactoryFactory.createFactory(JobPersistenceComponentFactory jobPersistenceComponentFactory,
Executor ioExecutor,
RpcService rpcService,
PartialDispatcherServices partialDispatcherServices,
FatalErrorHandler fatalErrorHandler) |
Constructor and Description |
---|
ApplicationDispatcherGatewayServiceFactory(Configuration configuration,
DispatcherFactory dispatcherFactory,
PackagedProgram application,
RpcService rpcService,
PartialDispatcherServices partialDispatcherServices) |
Modifier and Type | Class and Description |
---|---|
class |
PartialDispatcherServicesWithJobPersistenceComponents
DispatcherFactory services container. |
Modifier and Type | Method and Description |
---|---|
static PartialDispatcherServicesWithJobPersistenceComponents |
PartialDispatcherServicesWithJobPersistenceComponents.from(PartialDispatcherServices partialDispatcherServices,
JobGraphWriter jobGraphWriter,
JobResultStore jobResultStore) |
Modifier and Type | Method and Description |
---|---|
DispatcherRunner |
DefaultDispatcherRunnerFactory.createDispatcherRunner(LeaderElectionService leaderElectionService,
FatalErrorHandler fatalErrorHandler,
JobPersistenceComponentFactory jobPersistenceComponentFactory,
Executor ioExecutor,
RpcService rpcService,
PartialDispatcherServices partialDispatcherServices) |
DispatcherRunner |
DispatcherRunnerFactory.createDispatcherRunner(LeaderElectionService leaderElectionService,
FatalErrorHandler fatalErrorHandler,
JobPersistenceComponentFactory jobPersistenceComponentFactory,
Executor ioExecutor,
RpcService rpcService,
PartialDispatcherServices partialDispatcherServices) |
DispatcherLeaderProcessFactory |
DispatcherLeaderProcessFactoryFactory.createFactory(JobPersistenceComponentFactory jobPersistenceComponentFactory,
Executor ioExecutor,
RpcService rpcService,
PartialDispatcherServices partialDispatcherServices,
FatalErrorHandler fatalErrorHandler) |
DispatcherLeaderProcessFactory |
SessionDispatcherLeaderProcessFactoryFactory.createFactory(JobPersistenceComponentFactory jobPersistenceComponentFactory,
Executor ioExecutor,
RpcService rpcService,
PartialDispatcherServices partialDispatcherServices,
FatalErrorHandler fatalErrorHandler) |
JobDispatcherLeaderProcessFactory |
JobDispatcherLeaderProcessFactoryFactory.createFactory(JobPersistenceComponentFactory jobPersistenceComponentFactory,
Executor ioExecutor,
RpcService rpcService,
PartialDispatcherServices partialDispatcherServices,
FatalErrorHandler fatalErrorHandler) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.