Modifier and Type | Class and Description |
---|---|
class |
KubernetesResourceManagerDriver
Implementation of
ResourceManagerDriver for Kubernetes deployment. |
Modifier and Type | Method and Description |
---|---|
protected ResourceManagerDriver<KubernetesWorkerNode> |
KubernetesResourceManagerFactory.createResourceManagerDriver(Configuration configuration,
String webInterfaceUrl,
String rpcAddress) |
Modifier and Type | Class and Description |
---|---|
class |
MesosResourceManagerDriver
Deprecated.
Apache Mesos support was deprecated in Flink 1.13 and is subject to removal in the
future (see FLINK-22352 for further details).
|
Modifier and Type | Method and Description |
---|---|
protected ResourceManagerDriver<RegisteredMesosWorkerNode> |
MesosResourceManagerFactory.createResourceManagerDriver(Configuration configuration,
String webInterfaceUrl,
String rpcAddress)
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractResourceManagerDriver<WorkerType extends ResourceIDRetrievable>
Abstract common base class for implementations of
ResourceManagerDriver . |
Modifier and Type | Method and Description |
---|---|
protected abstract ResourceManagerDriver<WorkerType> |
ActiveResourceManagerFactory.createResourceManagerDriver(Configuration configuration,
String webInterfaceUrl,
String rpcAddress) |
Constructor and Description |
---|
ActiveResourceManager(ResourceManagerDriver<WorkerType> resourceManagerDriver,
Configuration flinkConfig,
RpcService rpcService,
ResourceID resourceId,
HighAvailabilityServices highAvailabilityServices,
HeartbeatServices heartbeatServices,
SlotManager slotManager,
ResourceManagerPartitionTrackerFactory clusterPartitionTrackerFactory,
JobLeaderIdService jobLeaderIdService,
ClusterInformation clusterInformation,
FatalErrorHandler fatalErrorHandler,
ResourceManagerMetricGroup resourceManagerMetricGroup,
ThresholdMeter startWorkerFailureRater,
java.time.Duration retryInterval,
java.time.Duration workerRegistrationTimeout,
Executor ioExecutor) |
Modifier and Type | Class and Description |
---|---|
class |
YarnResourceManagerDriver
Implementation of
ResourceManagerDriver for Yarn deployment. |
Modifier and Type | Method and Description |
---|---|
protected ResourceManagerDriver<YarnWorkerNode> |
YarnResourceManagerFactory.createResourceManagerDriver(Configuration configuration,
String webInterfaceUrl,
String rpcAddress) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.