Package | Description |
---|---|
org.apache.flink.kubernetes.entrypoint | |
org.apache.flink.runtime.resourcemanager | |
org.apache.flink.yarn.entrypoint |
Modifier and Type | Method and Description |
---|---|
protected ResourceManagerRuntimeServicesConfiguration |
KubernetesResourceManagerFactory.createResourceManagerRuntimeServicesConfiguration(Configuration configuration) |
Modifier and Type | Method and Description |
---|---|
protected ResourceManagerRuntimeServicesConfiguration |
StandaloneResourceManagerFactory.createResourceManagerRuntimeServicesConfiguration(Configuration configuration) |
protected abstract ResourceManagerRuntimeServicesConfiguration |
ResourceManagerFactory.createResourceManagerRuntimeServicesConfiguration(Configuration configuration) |
static ResourceManagerRuntimeServicesConfiguration |
ResourceManagerRuntimeServicesConfiguration.fromConfiguration(Configuration configuration,
WorkerResourceSpecFactory defaultWorkerResourceSpecFactory) |
ResourceManagerRuntimeServicesConfiguration |
ResourceManagerProcessContext.getRmRuntimeServicesConfig() |
Modifier and Type | Method and Description |
---|---|
static ResourceManagerRuntimeServices |
ResourceManagerRuntimeServices.fromConfiguration(ResourceManagerRuntimeServicesConfiguration configuration,
HighAvailabilityServices highAvailabilityServices,
ScheduledExecutor scheduledExecutor,
SlotManagerMetricGroup slotManagerMetricGroup) |
Constructor and Description |
---|
ResourceManagerProcessContext(Configuration rmConfig,
ResourceID resourceId,
ResourceManagerRuntimeServicesConfiguration rmRuntimeServicesConfig,
RpcService rpcService,
HighAvailabilityServices highAvailabilityServices,
HeartbeatServices heartbeatServices,
DelegationTokenManager delegationTokenManager,
FatalErrorHandler fatalErrorHandler,
ClusterInformation clusterInformation,
String webInterfaceUrl,
MetricRegistry metricRegistry,
String hostname,
Executor ioExecutor) |
Modifier and Type | Method and Description |
---|---|
protected ResourceManagerRuntimeServicesConfiguration |
YarnResourceManagerFactory.createResourceManagerRuntimeServicesConfiguration(Configuration configuration) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.