Package org.apache.flink.cdc.common.configuration

Class Configuration

java.lang.Object

org.apache.flink.cdc.common.configuration.Configuration

All Implemented Interfaces:

Serializable, Cloneable

public class Configuration
extends Object
implements Serializable, Cloneable

Lightweight configuration object which stores key/value pairs.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected HashMap<String,Object>	confData	Stores the concrete key/value pairs of this configuration object.

Constructor Summary

Constructors

Constructor	Description
Configuration()	Creates a new empty configuration.
Configuration(Configuration other)	Creates a new configuration with the copy of the given configuration.

Method Summary

Modifier and Type	Method	Description
void	addAll(Configuration other)
Configuration	clone()
boolean	contains(ConfigOption<?> configOption)	Checks whether there is an entry for the given config option.
boolean	equals(Object obj)
static Configuration	fromMap(Map<String,String> map)	Creates a new configuration that is initialized with the options of the given map.
<T> T	get(ConfigOption<T> option)
Set<String>	getKeys()
<T> Optional<T>	getOptional(ConfigOption<T> option)
int	hashCode()
Set<String>	keySet()	Returns the keys of all key/value pairs stored inside this configuration object.
<T> boolean	remove(ConfigOption<T> configOption)	Removes given config option from the configuration.
<T> Configuration	set(ConfigOption<T> option, T value)
Map<String,String>	toMap()
String	toString()

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

confData

protected final HashMap<String,Object> confData

Stores the concrete key/value pairs of this configuration object.

Constructor Detail

Configuration

public Configuration()

Creates a new empty configuration.

Configuration

public Configuration(Configuration other)

Creates a new configuration with the copy of the given configuration.

Parameters:

other - The configuration to copy the entries from.

Method Detail

fromMap

public static Configuration fromMap(Map<String,String> map)

Creates a new configuration that is initialized with the options of the given map.

addAll

public void addAll(Configuration other)

clone

public Configuration clone()

Overrides:

clone in class Object

contains

public boolean contains(ConfigOption<?> configOption)

Checks whether there is an entry for the given config option.

Parameters:

configOption - The configuration option

Returns:

true if a valid (current or deprecated) key of the config option is stored, false otherwise

get

public <T> T get(ConfigOption<T> option)

getOptional

public <T> Optional<T> getOptional(ConfigOption<T> option)

set

public <T> Configuration set(ConfigOption<T> option,
                             T value)

keySet

public Set<String> keySet()

Returns the keys of all key/value pairs stored inside this configuration object.

Returns:

the keys of all key/value pairs stored inside this configuration object

toMap

public Map<String,String> toMap()

remove

public <T> boolean remove(ConfigOption<T> configOption)

Removes given config option from the configuration.

Type Parameters:

T - Type of the config option

Parameters:

configOption - config option to remove

Returns:

true is config has been removed, false otherwise

getKeys

public Set<String> getKeys()

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object