org.apache.flink.yarn.entrypoint

类 YarnResourceManagerFactory

java.lang.Object

org.apache.flink.runtime.resourcemanager.ActiveResourceManagerFactory<YarnWorkerNode>

org.apache.flink.yarn.entrypoint.YarnResourceManagerFactory

所有已实现的接口:

org.apache.flink.runtime.resourcemanager.ResourceManagerFactory<YarnWorkerNode>

public class YarnResourceManagerFactory
extends org.apache.flink.runtime.resourcemanager.ActiveResourceManagerFactory<YarnWorkerNode>

ResourceManagerFactory implementation which creates a YarnResourceManager.

方法概要

限定符和类型	方法和说明
org.apache.flink.runtime.resourcemanager.ResourceManager<YarnWorkerNode>	createActiveResourceManager(org.apache.flink.configuration.Configuration configuration, org.apache.flink.runtime.clusterframework.types.ResourceID resourceId, org.apache.flink.runtime.rpc.RpcService rpcService, org.apache.flink.runtime.highavailability.HighAvailabilityServices highAvailabilityServices, org.apache.flink.runtime.heartbeat.HeartbeatServices heartbeatServices, org.apache.flink.runtime.rpc.FatalErrorHandler fatalErrorHandler, org.apache.flink.runtime.entrypoint.ClusterInformation clusterInformation, String webInterfaceUrl, org.apache.flink.runtime.metrics.groups.ResourceManagerMetricGroup resourceManagerMetricGroup)
static YarnResourceManagerFactory	getInstance()

从类继承的方法 org.apache.flink.runtime.resourcemanager.ActiveResourceManagerFactory

createActiveResourceManagerConfiguration, createResourceManager

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 org.apache.flink.runtime.resourcemanager.ResourceManagerFactory

generateEndpointIdWithUUID, getEndpointId

方法详细资料

getInstance

public static YarnResourceManagerFactory getInstance()

createActiveResourceManager

public org.apache.flink.runtime.resourcemanager.ResourceManager<YarnWorkerNode> createActiveResourceManager(org.apache.flink.configuration.Configuration configuration,
                                                                                                            org.apache.flink.runtime.clusterframework.types.ResourceID resourceId,
                                                                                                            org.apache.flink.runtime.rpc.RpcService rpcService,
                                                                                                            org.apache.flink.runtime.highavailability.HighAvailabilityServices highAvailabilityServices,
                                                                                                            org.apache.flink.runtime.heartbeat.HeartbeatServices heartbeatServices,
                                                                                                            org.apache.flink.runtime.rpc.FatalErrorHandler fatalErrorHandler,
                                                                                                            org.apache.flink.runtime.entrypoint.ClusterInformation clusterInformation,
                                                                                                            @Nullable
                                                                                                            String webInterfaceUrl,
                                                                                                            org.apache.flink.runtime.metrics.groups.ResourceManagerMetricGroup resourceManagerMetricGroup)
                                                                                                     throws Exception

指定者:

createActiveResourceManager 在类中 org.apache.flink.runtime.resourcemanager.ActiveResourceManagerFactory<YarnWorkerNode>

抛出:

Exception