Class CLI
- java.lang.Object
-
- org.apache.flink.api.common.ExecutionConfig.GlobalJobParameters
-
- org.apache.flink.streaming.examples.wordcount.util.CLI
-
- All Implemented Interfaces:
Serializable
public class CLI extends ExecutionConfig.GlobalJobParameters
A simple CLI parser for theWordCount
example application.- See Also:
- Serialized Form
-
-
Field Summary
Fields Modifier and Type Field Description static String
DISCOVERY_INTERVAL
static String
EXECUTION_MODE
static String
INPUT_KEY
static String
OUTPUT_KEY
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
equals(Object o)
static CLI
fromArgs(String[] args)
Optional<Duration>
getDiscoveryInterval()
RuntimeExecutionMode
getExecutionMode()
Optional<Path[]>
getInputs()
OptionalInt
getInt(String key)
Optional<Path>
getOutput()
int
hashCode()
Map<String,String>
toMap()
Convert UserConfig into aMap<String, String>
representation.
-
-
-
Field Detail
-
INPUT_KEY
public static final String INPUT_KEY
- See Also:
- Constant Field Values
-
OUTPUT_KEY
public static final String OUTPUT_KEY
- See Also:
- Constant Field Values
-
DISCOVERY_INTERVAL
public static final String DISCOVERY_INTERVAL
- See Also:
- Constant Field Values
-
EXECUTION_MODE
public static final String EXECUTION_MODE
- See Also:
- Constant Field Values
-
-
Method Detail
-
getExecutionMode
public RuntimeExecutionMode getExecutionMode()
-
getInt
public OptionalInt getInt(String key)
-
toMap
public Map<String,String> toMap()
Description copied from class:ExecutionConfig.GlobalJobParameters
Convert UserConfig into aMap<String, String>
representation. This can be used by the runtime, for example for presenting the user config in the web frontend.- Overrides:
toMap
in classExecutionConfig.GlobalJobParameters
- Returns:
- Key/Value representation of the UserConfig
-
equals
public boolean equals(Object o)
- Overrides:
equals
in classExecutionConfig.GlobalJobParameters
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classExecutionConfig.GlobalJobParameters
-
-