public class FlinkYarnSessionCli extends AbstractCustomCommandLine
addressOption, configuration, zookeeperNamespaceOption
Constructor and Description |
---|
FlinkYarnSessionCli(Configuration configuration,
ClusterClientServiceLoader clusterClientServiceLoader,
String configurationDirectory,
String shortPrefix,
String longPrefix,
boolean acceptInteractiveInput) |
FlinkYarnSessionCli(Configuration configuration,
String configurationDirectory,
String shortPrefix,
String longPrefix) |
FlinkYarnSessionCli(Configuration configuration,
String configurationDirectory,
String shortPrefix,
String longPrefix,
boolean acceptInteractiveInput) |
Modifier and Type | Method and Description |
---|---|
void |
addGeneralOptions(org.apache.commons.cli.Options baseOptions)
Adds custom options to the existing general options.
|
void |
addRunOptions(org.apache.commons.cli.Options baseOptions)
Adds custom options to the existing run options.
|
Configuration |
applyCommandLineOptionsToConfiguration(org.apache.commons.cli.CommandLine commandLine)
Override configuration settings by specified command line options.
|
static Map<String,String> |
getDynamicProperties(String dynamicPropertiesEncoded) |
String |
getId()
Gets the unique identifier of this CustomCommandLine.
|
static File |
getYarnPropertiesLocation(String yarnPropertiesFileLocation) |
boolean |
isActive(org.apache.commons.cli.CommandLine commandLine)
Signals whether the custom command-line wants to execute or not.
|
static void |
main(String[] args) |
int |
run(String[] args) |
getConfiguration, handleCliArgsException, handleError, printUsage
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
parseCommandLineOptions
public FlinkYarnSessionCli(Configuration configuration, String configurationDirectory, String shortPrefix, String longPrefix) throws FlinkException
FlinkException
public FlinkYarnSessionCli(Configuration configuration, String configurationDirectory, String shortPrefix, String longPrefix, boolean acceptInteractiveInput) throws FlinkException
FlinkException
public FlinkYarnSessionCli(Configuration configuration, ClusterClientServiceLoader clusterClientServiceLoader, String configurationDirectory, String shortPrefix, String longPrefix, boolean acceptInteractiveInput) throws FlinkException
FlinkException
public boolean isActive(org.apache.commons.cli.CommandLine commandLine)
CustomCommandLine
commandLine
- The command-line optionspublic String getId()
CustomCommandLine
public void addRunOptions(org.apache.commons.cli.Options baseOptions)
CustomCommandLine
addRunOptions
in interface CustomCommandLine
addRunOptions
in class AbstractCustomCommandLine
baseOptions
- The existing options.public void addGeneralOptions(org.apache.commons.cli.Options baseOptions)
CustomCommandLine
addGeneralOptions
in interface CustomCommandLine
addGeneralOptions
in class AbstractCustomCommandLine
baseOptions
- The existing options.public Configuration applyCommandLineOptionsToConfiguration(org.apache.commons.cli.CommandLine commandLine) throws FlinkException
CustomCommandLine
applyCommandLineOptionsToConfiguration
in interface CustomCommandLine
applyCommandLineOptionsToConfiguration
in class AbstractCustomCommandLine
commandLine
- containing the overriding valuesFlinkException
public int run(String[] args) throws CliArgsException, FlinkException
CliArgsException
FlinkException
public static Map<String,String> getDynamicProperties(String dynamicPropertiesEncoded)
public static void main(String[] args)
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.