org.apache.flink.yarn.entrypoint

类 YarnEntrypointUtils

java.lang.Object

org.apache.flink.yarn.entrypoint.YarnEntrypointUtils

public class YarnEntrypointUtils
extends Object

This class contains utility methods for the YarnSessionClusterEntrypoint and YarnJobClusterEntrypoint.

构造器概要

构造器

构造器和说明
YarnEntrypointUtils()

方法概要

限定符和类型	方法和说明
static org.apache.flink.runtime.security.SecurityContext	installSecurityContext(org.apache.flink.configuration.Configuration configuration)
static org.apache.flink.configuration.Configuration	loadConfiguration(String workingDirectory, Map<String,String> env)
static void	logYarnEnvironmentInformation(Map<String,String> env, org.slf4j.Logger log)

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

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

构造器详细资料

YarnEntrypointUtils

public YarnEntrypointUtils()

方法详细资料

installSecurityContext

public static org.apache.flink.runtime.security.SecurityContext installSecurityContext(org.apache.flink.configuration.Configuration configuration)
                                                                                throws Exception

抛出:

Exception

loadConfiguration

public static org.apache.flink.configuration.Configuration loadConfiguration(String workingDirectory,
                                                                             Map<String,String> env)

logYarnEnvironmentInformation

public static void logYarnEnvironmentInformation(Map<String,String> env,
                                                 org.slf4j.Logger log)
                                          throws IOException

抛出:

IOException