Package | Description |
---|---|
org.apache.flink.runtime.dispatcher |
Modifier and Type | Method and Description |
---|---|
static DispatcherServices |
DispatcherServices.from(PartialDispatcherServicesWithJobGraphStore partialDispatcherServicesWithJobGraphStore,
JobManagerRunnerFactory jobManagerRunnerFactory) |
Constructor and Description |
---|
Dispatcher(RpcService rpcService,
String endpointId,
DispatcherId fencingToken,
Collection<JobGraph> recoveredJobs,
DispatcherServices dispatcherServices) |
MiniDispatcher(RpcService rpcService,
String endpointId,
DispatcherId fencingToken,
DispatcherServices dispatcherServices,
JobGraph jobGraph,
ClusterEntrypoint.ExecutionMode executionMode) |
StandaloneDispatcher(RpcService rpcService,
String endpointId,
DispatcherId fencingToken,
Collection<JobGraph> recoveredJobs,
DispatcherServices dispatcherServices) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.