Uses of Class
org.apache.flink.runtime.entrypoint.ClusterInformation

Packages that use ClusterInformation

Package	Description
org.apache.flink.runtime.minicluster
org.apache.flink.runtime.resourcemanager
org.apache.flink.runtime.resourcemanager.active
org.apache.flink.runtime.taskexecutor

Uses of ClusterInformation in org.apache.flink.runtime.minicluster

Methods in org.apache.flink.runtime.minicluster that return ClusterInformation

Modifier and Type	Method and Description
ClusterInformation	MiniCluster.getClusterInformation()

Uses of ClusterInformation in org.apache.flink.runtime.resourcemanager

Methods in org.apache.flink.runtime.resourcemanager that return ClusterInformation

Modifier and Type	Method and Description
ClusterInformation	ResourceManagerProcessContext.getClusterInformation()

Methods in org.apache.flink.runtime.resourcemanager with parameters of type ClusterInformation

Modifier and Type	Method and Description
static ResourceManagerServiceImpl	ResourceManagerServiceImpl.create(ResourceManagerFactory<?> resourceManagerFactory, Configuration configuration, ResourceID resourceId, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, String webInterfaceUrl, MetricRegistry metricRegistry, String hostname, Executor ioExecutor)
protected ResourceManager<ResourceID>	StandaloneResourceManagerFactory.createResourceManager(Configuration configuration, ResourceID resourceId, RpcService rpcService, UUID leaderSessionId, HeartbeatServices heartbeatServices, FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, String webInterfaceUrl, ResourceManagerMetricGroup resourceManagerMetricGroup, ResourceManagerRuntimeServices resourceManagerRuntimeServices, Executor ioExecutor)
protected abstract ResourceManager<T>	ResourceManagerFactory.createResourceManager(Configuration configuration, ResourceID resourceId, RpcService rpcService, UUID leaderSessionId, HeartbeatServices heartbeatServices, FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, String webInterfaceUrl, ResourceManagerMetricGroup resourceManagerMetricGroup, ResourceManagerRuntimeServices resourceManagerRuntimeServices, Executor ioExecutor)
ResourceManagerProcessContext	ResourceManagerFactory.createResourceManagerProcessContext(Configuration configuration, ResourceID resourceId, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, String webInterfaceUrl, MetricRegistry metricRegistry, String hostname, Executor ioExecutor)

Constructors in org.apache.flink.runtime.resourcemanager with parameters of type ClusterInformation

Constructor and Description
ResourceManager(RpcService rpcService, UUID leaderSessionId, ResourceID resourceId, HeartbeatServices heartbeatServices, SlotManager slotManager, ResourceManagerPartitionTrackerFactory clusterPartitionTrackerFactory, JobLeaderIdService jobLeaderIdService, ClusterInformation clusterInformation, FatalErrorHandler fatalErrorHandler, ResourceManagerMetricGroup resourceManagerMetricGroup, Time rpcTimeout, Executor ioExecutor)
ResourceManagerProcessContext(Configuration rmConfig, ResourceID resourceId, ResourceManagerRuntimeServicesConfiguration rmRuntimeServicesConfig, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, String webInterfaceUrl, MetricRegistry metricRegistry, String hostname, Executor ioExecutor)
StandaloneResourceManager(RpcService rpcService, UUID leaderSessionId, ResourceID resourceId, HeartbeatServices heartbeatServices, SlotManager slotManager, ResourceManagerPartitionTrackerFactory clusterPartitionTrackerFactory, JobLeaderIdService jobLeaderIdService, ClusterInformation clusterInformation, FatalErrorHandler fatalErrorHandler, ResourceManagerMetricGroup resourceManagerMetricGroup, Time startupPeriodTime, Time rpcTimeout, Executor ioExecutor)

Uses of ClusterInformation in org.apache.flink.runtime.resourcemanager.active

Methods in org.apache.flink.runtime.resourcemanager.active with parameters of type ClusterInformation

Modifier and Type

Method and Description

ResourceManager<WorkerType>

ActiveResourceManagerFactory.createResourceManager(Configuration configuration, ResourceID resourceId, RpcService rpcService, UUID leaderSessionId, HeartbeatServices heartbeatServices, FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, String webInterfaceUrl, ResourceManagerMetricGroup resourceManagerMetricGroup, ResourceManagerRuntimeServices resourceManagerRuntimeServices, Executor ioExecutor)

Constructors in org.apache.flink.runtime.resourcemanager.active with parameters of type ClusterInformation

Constructor and Description

ActiveResourceManager(ResourceManagerDriver<WorkerType> resourceManagerDriver, Configuration flinkConfig, RpcService rpcService, UUID leaderSessionId, ResourceID resourceId, 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)

Uses of ClusterInformation in org.apache.flink.runtime.taskexecutor

Methods in org.apache.flink.runtime.taskexecutor that return ClusterInformation

Modifier and Type	Method and Description
ClusterInformation	TaskExecutorRegistrationSuccess.getClusterInformation() Gets the cluster information.

Constructors in org.apache.flink.runtime.taskexecutor with parameters of type ClusterInformation

Constructor and Description
TaskExecutorRegistrationSuccess(InstanceID registrationId, ResourceID resourceManagerResourceId, ClusterInformation clusterInformation) Create a new TaskExecutorRegistrationSuccess message.