org.apache.flink.storm.util

Class StormConfig

java.lang.Object

org.apache.flink.api.common.ExecutionConfig.GlobalJobParameters

org.apache.flink.storm.util.StormConfig

All Implemented Interfaces:

Serializable, Map

public final class StormConfig
extends ExecutionConfig.GlobalJobParameters
implements Map

StormConfig is used to provide a user-defined Storm configuration (ie, a raw Map or Config object) for embedded Spouts and Bolts.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface java.util.Map

Map.Entry<K,V>

Constructor Summary

Constructors

Constructor and Description
StormConfig() Creates an empty configuration.
StormConfig(Map config) Creates an configuration with initial values provided by the given Map.

Method Summary

Modifier and Type	Method and Description
void	clear()
boolean	containsKey(Object key)
boolean	containsValue(Object value)
Set<Map.Entry<Object,Object>>	entrySet()
Object	get(Object key)
boolean	isEmpty()
Set<Object>	keySet()
Object	put(Object key, Object value)
void	putAll(Map m)
Object	remove(Object key)
int	size()
Collection<Object>	values()

Methods inherited from class org.apache.flink.api.common.ExecutionConfig.GlobalJobParameters

toMap

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.Map

compute, computeIfAbsent, computeIfPresent, equals, forEach, getOrDefault, hashCode, merge, putIfAbsent, remove, replace, replace, replaceAll

Constructor Detail

StormConfig

public StormConfig()

Creates an empty configuration.

StormConfig

public StormConfig(Map config)

Creates an configuration with initial values provided by the given Map.

Parameters:

config - Initial values for this configuration.

Method Detail

size

public int size()

Specified by:

size in interface Map

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface Map

containsKey

public boolean containsKey(Object key)

Specified by:

containsKey in interface Map

containsValue

public boolean containsValue(Object value)

Specified by:

containsValue in interface Map

get

public Object get(Object key)

Specified by:

get in interface Map

put

public Object put(Object key,
                  Object value)

Specified by:

put in interface Map

remove

public Object remove(Object key)

Specified by:

remove in interface Map

putAll

public void putAll(Map m)

Specified by:

putAll in interface Map

clear

public void clear()

Specified by:

clear in interface Map

keySet

public Set<Object> keySet()

Specified by:

keySet in interface Map

values

public Collection<Object> values()

Specified by:

values in interface Map

entrySet

public Set<Map.Entry<Object,Object>> entrySet()

Specified by:

entrySet in interface Map