Class ParameterMap

java.lang.Object

java.util.AbstractMap<String,Object>

java.util.concurrent.ConcurrentHashMap<String,Object>

io.nosqlbench.nb.api.engine.activityimpl.ParameterMap

All Implemented Interfaces:

Serializable, ConcurrentMap<String,Object>, Map<String,Object>, Bindings, org.graalvm.polyglot.proxy.Proxy, org.graalvm.polyglot.proxy.ProxyObject

public class ParameterMap
extends ConcurrentHashMap<String,Object>
implements Bindings, org.graalvm.polyglot.proxy.ProxyObject

A concurrently accessible parameter map which holds both keys and values as strings. An atomic change counter tracks updates, to allow interested consumers to determine when to re-read values across threads. The basic format is <paramname>=<paramvalue>;...

To create a parameter map, use one of the static parse... methods.

No non-String types are used internally. Everything is encoded as a String, even though the generic type is parameterized for Bindings support.

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	ParameterMap.Listener
static class	ParameterMap.NamedParameter

Nested classes/interfaces inherited from class java.util.concurrent.ConcurrentHashMap

ConcurrentHashMap.KeySetView<K,V>

Nested classes/interfaces inherited from class java.util.AbstractMap

AbstractMap.SimpleEntry<K,V>, AbstractMap.SimpleImmutableEntry<K,V>

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

Map.Entry<K,V>

Constructor Summary

Constructors

Constructor	Description
ParameterMap(Map<String,String> valueMap)

Method Summary

Modifier and Type	Method	Description
void	addListener(ParameterMap.Listener listener)
void	assertOnlyOneOf(String... paramName)
void	clear()
Set<Map.Entry<String,Object>>	entrySet()
Object	get(Object key)
AtomicLong	getChangeCounter()	Get the atomic change counter for this parameter map.
Object	getMember(String key)
Object	getMemberKeys()
Optional<Boolean>	getOptionalBoolean(String paramName)
Optional<Double>	getOptionalDouble(String paramName)
Optional<Double>	getOptionalDoubleBytes(String paramName)
Optional<Double>	getOptionalDoubleUnitCount(String paramName)
Optional<Integer>	getOptionalInteger(String paramName)
Optional<Long>	getOptionalLong(String paramName)
Optional<Long>	getOptionalLongBytes(String paramName)
Optional<Long>	getOptionalLongUnitCount(String paramName)
Optional<Long>	getOptionalMillisUnit(String paramName)
Optional<ParameterMap.NamedParameter>	getOptionalNamedParameter(String... paramName)
Optional<String>	getOptionalString(String... paramName)
int	getSize()
Map<String,String>	getStringStringMap()
boolean	hasMember(String key)
static ParameterMap	parseOrException(String encodedParams)
static Optional<ParameterMap>	parseParams(String encodedParams)
Object	put(String name, Object value)
void	putAll(Map<? extends String,? extends Object> toMerge)
void	putMember(String key, org.graalvm.polyglot.Value value)
Object	remove(Object key)
void	removeListener(ParameterMap.Listener listener)
boolean	removeMember(String key)
Optional<String>	removeOptionalString(String... paramName)
void	set(String paramName, Object newValue)
void	setSilently(String paramName, Object newValue)
boolean	takeBoolOrDefault(String paramName, boolean defaultBoolValue)
Double	takeDoubleOrDefault(String paramName, double defaultDoubleValue)
int	takeIntOrDefault(String paramName, int paramDefault)
Long	takeLongOrDefault(String paramName, Long defaultLongValue)
String	takeStringOrDefault(String paramName, String defaultStringValue)
static String	toJSON(Map<?,?> map)
String	toString()

Methods inherited from class java.util.concurrent.ConcurrentHashMap

compute, computeIfAbsent, computeIfPresent, contains, containsKey, containsValue, elements, equals, forEach, forEach, forEach, forEachEntry, forEachEntry, forEachKey, forEachKey, forEachValue, forEachValue, getOrDefault, hashCode, isEmpty, keys, keySet, keySet, mappingCount, merge, newKeySet, newKeySet, putIfAbsent, reduce, reduceEntries, reduceEntries, reduceEntriesToDouble, reduceEntriesToInt, reduceEntriesToLong, reduceKeys, reduceKeys, reduceKeysToDouble, reduceKeysToInt, reduceKeysToLong, reduceToDouble, reduceToInt, reduceToLong, reduceValues, reduceValues, reduceValuesToDouble, reduceValuesToInt, reduceValuesToLong, remove, replace, replace, replaceAll, search, searchEntries, searchKeys, searchValues, size, values

Methods inherited from class java.util.AbstractMap

clone

Methods inherited from class java.lang.Object

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

Methods inherited from interface javax.script.Bindings

containsKey

Methods inherited from interface java.util.Map

containsValue, equals, hashCode, isEmpty, keySet, size, values

Constructor Details

ParameterMap

public ParameterMap(Map<String,String> valueMap)

Method Details

assertOnlyOneOf

public void assertOnlyOneOf(String... paramName)

getOptionalString

public Optional<String> getOptionalString(String... paramName)

removeOptionalString

public Optional<String> removeOptionalString(String... paramName)

getOptionalNamedParameter

public Optional<ParameterMap.NamedParameter> getOptionalNamedParameter(String... paramName)

getOptionalLong

public Optional<Long> getOptionalLong(String paramName)

getOptionalMillisUnit

public Optional<Long> getOptionalMillisUnit(String paramName)

getOptionalLongUnitCount

public Optional<Long> getOptionalLongUnitCount(String paramName)

getOptionalDoubleUnitCount

public Optional<Double> getOptionalDoubleUnitCount(String paramName)

getOptionalLongBytes

public Optional<Long> getOptionalLongBytes(String paramName)

getOptionalDoubleBytes

public Optional<Double> getOptionalDoubleBytes(String paramName)

getOptionalDouble

public Optional<Double> getOptionalDouble(String paramName)

getOptionalBoolean

public Optional<Boolean> getOptionalBoolean(String paramName)

takeLongOrDefault

public Long takeLongOrDefault(String paramName,
 Long defaultLongValue)

takeDoubleOrDefault

public Double takeDoubleOrDefault(String paramName,
 double defaultDoubleValue)

takeStringOrDefault

public String takeStringOrDefault(String paramName,
 String defaultStringValue)

takeIntOrDefault

public int takeIntOrDefault(String paramName,
 int paramDefault)

takeBoolOrDefault

public boolean takeBoolOrDefault(String paramName,
 boolean defaultBoolValue)

get

public Object get(Object key)

Specified by:

get in interface Bindings

Specified by:

get in interface Map<String,Object>

Overrides:

get in class ConcurrentHashMap<String,Object>

setSilently

public void setSilently(String paramName,
 Object newValue)

set

public void set(String paramName,
 Object newValue)

put

public Object put(String name,
 Object value)

Specified by:

put in interface Bindings

Specified by:

put in interface Map<String,Object>

Overrides:

put in class ConcurrentHashMap<String,Object>

putAll

public void putAll(Map<? extends String,? extends Object> toMerge)

Specified by:

putAll in interface Bindings

Specified by:

putAll in interface Map<String,Object>

Overrides:

putAll in class ConcurrentHashMap<String,Object>

remove

public Object remove(Object key)

Specified by:

remove in interface Bindings

Specified by:

remove in interface Map<String,Object>

Overrides:

remove in class ConcurrentHashMap<String,Object>

clear

public void clear()

Specified by:

clear in interface Map<String,Object>

Overrides:

clear in class ConcurrentHashMap<String,Object>

entrySet

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

Specified by:

entrySet in interface Map<String,Object>

Overrides:

entrySet in class ConcurrentHashMap<String,Object>

getChangeCounter

public AtomicLong getChangeCounter()

Get the atomic change counter for this parameter map. It getes incremented whenever any changes are made to the map.

Returns:

the atomic long change counter

toString

public String toString()

Overrides:

toString in class ConcurrentHashMap<String,Object>

addListener

public void addListener(ParameterMap.Listener listener)

removeListener

public void removeListener(ParameterMap.Listener listener)

getSize

public int getSize()

parseOrException

public static ParameterMap parseOrException(String encodedParams)

parseParams

public static Optional<ParameterMap> parseParams(String encodedParams)

getOptionalInteger

public Optional<Integer> getOptionalInteger(String paramName)

getMember

public Object getMember(String key)

Specified by:

getMember in interface org.graalvm.polyglot.proxy.ProxyObject

getMemberKeys

public Object getMemberKeys()

Specified by:

getMemberKeys in interface org.graalvm.polyglot.proxy.ProxyObject

hasMember

public boolean hasMember(String key)

Specified by:

hasMember in interface org.graalvm.polyglot.proxy.ProxyObject

putMember

public void putMember(String key,
 org.graalvm.polyglot.Value value)

Specified by:

putMember in interface org.graalvm.polyglot.proxy.ProxyObject

removeMember

public boolean removeMember(String key)

Specified by:

removeMember in interface org.graalvm.polyglot.proxy.ProxyObject

getStringStringMap

public Map<String,String> getStringStringMap()

toJSON

public static String toJSON(Map<?,?> map)