org.apache.flink.streaming.examples.wordcount.util

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 the WordCount example application.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static String	DISCOVERY_INTERVAL
static String	EXECUTION_MODE
static String	INPUT_KEY
static String	OUTPUT_KEY

Method Summary

Modifier and Type	Method and 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 a Map<String, String> representation.

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

Method Detail

fromArgs

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

Throws:

Exception

getInputs

public Optional<Path[]> getInputs()

getDiscoveryInterval

public Optional<Duration> getDiscoveryInterval()

getOutput

public Optional<Path> getOutput()

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 a Map<String, String> representation. This can be used by the runtime, for example for presenting the user config in the web frontend.

Overrides:

toMap in class ExecutionConfig.GlobalJobParameters

Returns:

Key/Value representation of the UserConfig

equals

public boolean equals(Object o)

Overrides:

equals in class ExecutionConfig.GlobalJobParameters

hashCode

public int hashCode()

Overrides:

hashCode in class ExecutionConfig.GlobalJobParameters