org.apache.flink.yarn.cli

类 FlinkYarnSessionCli

java.lang.Object

org.apache.flink.client.cli.AbstractCustomCommandLine

org.apache.flink.yarn.cli.FlinkYarnSessionCli

所有已实现的接口:

org.apache.flink.client.cli.CustomCommandLine

public class FlinkYarnSessionCli
extends org.apache.flink.client.cli.AbstractCustomCommandLine

Class handling the command line interface to the YARN session.

字段概要

字段

限定符和类型	字段和说明
static String	CONFIG_FILE_LOG4J_NAME
static String	CONFIG_FILE_LOGBACK_NAME

从类继承的字段 org.apache.flink.client.cli.AbstractCustomCommandLine

addressOption, configuration, zookeeperNamespaceOption

构造器概要

构造器

构造器和说明
FlinkYarnSessionCli(org.apache.flink.configuration.Configuration configuration, org.apache.flink.client.deployment.ClusterClientServiceLoader clusterClientServiceLoader, String configurationDirectory, String shortPrefix, String longPrefix, boolean acceptInteractiveInput)
FlinkYarnSessionCli(org.apache.flink.configuration.Configuration configuration, String configurationDirectory, String shortPrefix, String longPrefix)
FlinkYarnSessionCli(org.apache.flink.configuration.Configuration configuration, String configurationDirectory, String shortPrefix, String longPrefix, boolean acceptInteractiveInput)

方法概要

限定符和类型	方法和说明
void	addGeneralOptions(org.apache.commons.cli.Options baseOptions)
void	addRunOptions(org.apache.commons.cli.Options baseOptions)
org.apache.flink.configuration.Configuration	applyCommandLineOptionsToConfiguration(org.apache.commons.cli.CommandLine commandLine)
static Map<String,String>	getDynamicProperties(String dynamicPropertiesEncoded)
String	getId()
static File	getYarnPropertiesLocation(String yarnPropertiesFileLocation)
boolean	isActive(org.apache.commons.cli.CommandLine commandLine)
static void	main(String[] args)
int	run(String[] args)
static org.apache.flink.configuration.Configuration	setLogConfigFileInConfig(org.apache.flink.configuration.Configuration configuration, String configurationDirectory)

从类继承的方法 org.apache.flink.client.cli.AbstractCustomCommandLine

getConfiguration, handleCliArgsException, handleError, printUsage

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

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

从接口继承的方法 org.apache.flink.client.cli.CustomCommandLine

parseCommandLineOptions

字段详细资料

CONFIG_FILE_LOGBACK_NAME

public static final String CONFIG_FILE_LOGBACK_NAME

另请参阅:

常量字段值

CONFIG_FILE_LOG4J_NAME

public static final String CONFIG_FILE_LOG4J_NAME

另请参阅:

常量字段值

构造器详细资料

FlinkYarnSessionCli

public FlinkYarnSessionCli(org.apache.flink.configuration.Configuration configuration,
                           String configurationDirectory,
                           String shortPrefix,
                           String longPrefix)
                    throws org.apache.flink.util.FlinkException

抛出:

org.apache.flink.util.FlinkException

FlinkYarnSessionCli

public FlinkYarnSessionCli(org.apache.flink.configuration.Configuration configuration,
                           String configurationDirectory,
                           String shortPrefix,
                           String longPrefix,
                           boolean acceptInteractiveInput)
                    throws org.apache.flink.util.FlinkException

抛出:

org.apache.flink.util.FlinkException

FlinkYarnSessionCli

public FlinkYarnSessionCli(org.apache.flink.configuration.Configuration configuration,
                           org.apache.flink.client.deployment.ClusterClientServiceLoader clusterClientServiceLoader,
                           String configurationDirectory,
                           String shortPrefix,
                           String longPrefix,
                           boolean acceptInteractiveInput)
                    throws org.apache.flink.util.FlinkException

抛出:

org.apache.flink.util.FlinkException

方法详细资料

isActive

public boolean isActive(org.apache.commons.cli.CommandLine commandLine)

getId

public String getId()

addRunOptions

public void addRunOptions(org.apache.commons.cli.Options baseOptions)

指定者:

addRunOptions 在接口中 org.apache.flink.client.cli.CustomCommandLine

覆盖:

addRunOptions 在类中 org.apache.flink.client.cli.AbstractCustomCommandLine

addGeneralOptions

public void addGeneralOptions(org.apache.commons.cli.Options baseOptions)

指定者:

addGeneralOptions 在接口中 org.apache.flink.client.cli.CustomCommandLine

覆盖:

addGeneralOptions 在类中 org.apache.flink.client.cli.AbstractCustomCommandLine

applyCommandLineOptionsToConfiguration

public org.apache.flink.configuration.Configuration applyCommandLineOptionsToConfiguration(org.apache.commons.cli.CommandLine commandLine)
                                                                                    throws org.apache.flink.util.FlinkException

指定者:

applyCommandLineOptionsToConfiguration 在接口中 org.apache.flink.client.cli.CustomCommandLine

覆盖:

applyCommandLineOptionsToConfiguration 在类中 org.apache.flink.client.cli.AbstractCustomCommandLine

抛出:

org.apache.flink.util.FlinkException

setLogConfigFileInConfig

@VisibleForTesting
public static org.apache.flink.configuration.Configuration setLogConfigFileInConfig(org.apache.flink.configuration.Configuration configuration,
                                                                                                       String configurationDirectory)

run

public int run(String[] args)
        throws org.apache.flink.client.cli.CliArgsException,
               org.apache.flink.util.FlinkException

抛出:

org.apache.flink.client.cli.CliArgsException

org.apache.flink.util.FlinkException

getDynamicProperties

public static Map<String,String> getDynamicProperties(String dynamicPropertiesEncoded)

main

public static void main(String[] args)

getYarnPropertiesLocation

public static File getYarnPropertiesLocation(@Nullable
                                             String yarnPropertiesFileLocation)