Package | Description |
---|---|
org.apache.flink.client | |
org.apache.flink.client.cli |
Modifier and Type | Method and Description |
---|---|
protected Client |
CliFrontend.getClient(CommandLineOptions options,
String programName,
int userParallelism,
boolean detachedMode)
Retrieves a
Client object from the given command line options and other parameters. |
protected ActorGateway |
CliFrontend.getJobManagerGateway(CommandLineOptions options)
Retrieves the
ActorGateway for the JobManager. |
protected void |
CliFrontend.updateConfig(CommandLineOptions options)
Updates the associated configuration with the given command line options
|
Modifier and Type | Class and Description |
---|---|
class |
CancelOptions
Command line options for the CANCEL command
|
class |
InfoOptions
Command line options for the INFO command
|
class |
ListOptions
Command line options for the LIST command
|
class |
ProgramOptions
Base class for command line options that refer to a JAR file program.
|
class |
RunOptions
Command line options for the RUN command.
|
class |
SavepointOptions
Command line options for the SAVEPOINT command
|
class |
StopOptions
Command line options for the STOP command
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.