public interface CustomCommandLine<ClusterType extends ClusterClient>
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.
|
ClusterType |
createCluster(String applicationName,
org.apache.commons.cli.CommandLine commandLine,
Configuration config)
Creates the client for the cluster
|
String |
getId()
Gets the unique identifier of this CustomCommandLine
|
boolean |
isActive(org.apache.commons.cli.CommandLine commandLine,
Configuration configuration)
Signals whether the custom command-line wants to execute or not
|
ClusterType |
retrieveCluster(org.apache.commons.cli.CommandLine commandLine,
Configuration config)
Retrieves a client for a running cluster
|
boolean isActive(org.apache.commons.cli.CommandLine commandLine, Configuration configuration)
commandLine
- The command-line optionsconfiguration
- The Flink configurationString getId()
void addRunOptions(org.apache.commons.cli.Options baseOptions)
baseOptions
- The existing options.void addGeneralOptions(org.apache.commons.cli.Options baseOptions)
baseOptions
- The existing options.ClusterType retrieveCluster(org.apache.commons.cli.CommandLine commandLine, Configuration config) throws UnsupportedOperationException
commandLine
- The command-line parameters from the CliFrontendconfig
- The Flink configUnsupportedOperationException
- if the operation is not supportedClusterType createCluster(String applicationName, org.apache.commons.cli.CommandLine commandLine, Configuration config) throws UnsupportedOperationException
applicationName
- The application name to usecommandLine
- The command-line options parsed by the CliFrontendconfig
- The Flink config to useUnsupportedOperationException
- if the operation is not supportedCopyright © 2014–2017 The Apache Software Foundation. All rights reserved.