public abstract class AbstractCustomCommandLine extends Object implements CustomCommandLine
CustomCommandLine
implementations which specify a JobManager address and a
ZooKeeper namespace.Modifier and Type | Field and Description |
---|---|
protected org.apache.commons.cli.Option |
addressOption |
protected Configuration |
configuration |
protected org.apache.commons.cli.Option |
zookeeperNamespaceOption |
Modifier | Constructor and Description |
---|---|
protected |
AbstractCustomCommandLine(Configuration configuration) |
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.
|
Configuration |
getConfiguration() |
static int |
handleCliArgsException(CliArgsException e,
org.slf4j.Logger logger) |
static int |
handleError(Throwable t,
org.slf4j.Logger logger) |
protected void |
printUsage() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getId, isActive, parseCommandLineOptions
protected final org.apache.commons.cli.Option zookeeperNamespaceOption
protected final org.apache.commons.cli.Option addressOption
protected final Configuration configuration
protected AbstractCustomCommandLine(Configuration configuration)
public Configuration getConfiguration()
public void addRunOptions(org.apache.commons.cli.Options baseOptions)
CustomCommandLine
addRunOptions
in interface CustomCommandLine
baseOptions
- The existing options.public void addGeneralOptions(org.apache.commons.cli.Options baseOptions)
CustomCommandLine
addGeneralOptions
in interface CustomCommandLine
baseOptions
- The existing options.public Configuration applyCommandLineOptionsToConfiguration(org.apache.commons.cli.CommandLine commandLine) throws FlinkException
CustomCommandLine
applyCommandLineOptionsToConfiguration
in interface CustomCommandLine
commandLine
- containing the overriding valuesFlinkException
protected void printUsage()
public static int handleCliArgsException(CliArgsException e, org.slf4j.Logger logger)
public static int handleError(Throwable t, org.slf4j.Logger logger)
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.