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 |
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,
UUID leaderSessionId,
ResourceID resourceId,
HeartbeatServices heartbeatServices,
DelegationTokenManager delegationTokenManager,
SlotManager slotManager,
ResourceManagerPartitionTrackerFactory clusterPartitionTrackerFactory,
BlocklistHandler.Factory blocklistHandlerFactory,
JobLeaderIdService jobLeaderIdService,
ClusterInformation clusterInformation,
FatalErrorHandler fatalErrorHandler,
ResourceManagerMetricGroup resourceManagerMetricGroup,
ThresholdMeter startWorkerFailureRater,
java.time.Duration retryInterval,
java.time.Duration workerRegistrationTimeout,
java.time.Duration previousWorkerRecoverTimeout,
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.