CLI (Flink : Examples : Streaming 2.0.1-cp2 API)

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 org.apache.flink.api.common.ExecutionConfig.GlobalJobParameters
```
A simple CLI parser for the WordCount example application.

See Also:

Serialized Form

Field Summary

Fields
Modifier and Type	Field	Description
`static String`	`ASYNC_STATE`
`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()`
`org.apache.flink.api.common.RuntimeExecutionMode`	`getExecutionMode()`
`Optional<org.apache.flink.core.fs.Path[]>`	`getInputs()`
`OptionalInt`	`getInt(String key)`
`Optional<org.apache.flink.core.fs.Path>`	`getOutput()`
`int`	`hashCode()`
`boolean`	`isAsyncState()`
`Map<String,String>`	`toMap()`

Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

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
- ASYNC_STATE
```
public static final String ASYNC_STATE
```
  See Also:
  
  Constant Field Values

Method Detail

fromArgs

public static CLI fromArgs(String[] args)
                    throws Exception

Throws:: Exception

getInputs

public Optional<org.apache.flink.core.fs.Path[]> getInputs()

getDiscoveryInterval

public Optional<Duration> getDiscoveryInterval()

getOutput

public Optional<org.apache.flink.core.fs.Path> getOutput()

getExecutionMode

public org.apache.flink.api.common.RuntimeExecutionMode getExecutionMode()

isAsyncState
```
public boolean isAsyncState()
```

getInt

public OptionalInt getInt(String key)

toMap
```
public Map<String,String> toMap()
```
Overrides:

toMap in class org.apache.flink.api.common.ExecutionConfig.GlobalJobParameters

equals
```
public boolean equals(Object o)
```
Overrides:

equals in class org.apache.flink.api.common.ExecutionConfig.GlobalJobParameters

hashCode
```
public int hashCode()
```
Overrides:

hashCode in class org.apache.flink.api.common.ExecutionConfig.GlobalJobParameters