Package 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 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	DISCOVERY_INTERVAL
static String	EXECUTION_MODE
static String	INPUT_KEY
static String	OUTPUT_KEY

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
static CLI	fromArgs(String[] args)
Optional<java.time.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()
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

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<java.time.Duration> getDiscoveryInterval()

getOutput

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

getExecutionMode

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

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