Package org.apache.ignite.internal.cluster

Class ClusterNodeLocalMapImpl<K,V>

java.lang.Object

java.util.AbstractMap<K,V>

java.util.concurrent.ConcurrentHashMap<K,V>

org.apache.ignite.internal.cluster.ClusterNodeLocalMapImpl<K,V>

All Implemented Interfaces:

Externalizable, Serializable, ConcurrentMap<K,V>, Map<K,V>

public class ClusterNodeLocalMapImpl<K,V>
extends ConcurrentHashMap<K,V>
implements ConcurrentMap<K,V>, Externalizable

Implementation for node-local storage.

ClusterNodeLocalMapImpl is similar to ThreadLocal in a way that its values are not distributed and kept only on local node (similar like ThreadLocal values are attached to the current thread only). Node-local values are used primarily by jobs executed from the remote nodes to keep intermediate state on the local node between executions.

ClusterNodeLocalMapImpl is a ConcurrentMap so it is trivial to use.

You can get an instance of ClusterNodeLocalMapImpl by calling IgniteCluster.nodeLocalMap() method.

See Also:

Serialized Form

Nested Class Summary

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

ConcurrentHashMap.KeySetView<K extends Object,V extends Object>

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

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

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

Map.Entry<K extends Object,V extends Object>

Constructor Summary

Constructors

Constructor	Description
ClusterNodeLocalMapImpl()	No-arg constructor is required by externalization.

Method Summary

Modifier and Type	Method	Description
void	readExternal(ObjectInput in)
protected Object	readResolve()	Reconstructs object on unmarshalling.
String	toString()
void	writeExternal(ObjectOutput out)

Methods inherited from class java.util.concurrent.ConcurrentHashMap

clear, compute, computeIfAbsent, computeIfPresent, contains, containsKey, containsValue, elements, entrySet, equals, forEach, forEach, forEach, forEachEntry, forEachEntry, forEachKey, forEachKey, forEachValue, forEachValue, get, getOrDefault, hashCode, isEmpty, keys, keySet, keySet, mappingCount, merge, newKeySet, newKeySet, put, putAll, putIfAbsent, reduce, reduceEntries, reduceEntries, reduceEntriesToDouble, reduceEntriesToInt, reduceEntriesToLong, reduceKeys, reduceKeys, reduceKeysToDouble, reduceKeysToInt, reduceKeysToLong, reduceToDouble, reduceToInt, reduceToLong, reduceValues, reduceValues, reduceValuesToDouble, reduceValuesToInt, reduceValuesToLong, remove, 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 java.util.concurrent.ConcurrentMap

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

Methods inherited from interface java.util.Map

clear, containsKey, containsValue, entrySet, equals, get, hashCode, isEmpty, keySet, put, putAll, remove, size, values

Constructor Detail

ClusterNodeLocalMapImpl

public ClusterNodeLocalMapImpl()

No-arg constructor is required by externalization.

Method Detail

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException

readResolve

protected Object readResolve()
                      throws ObjectStreamException

Reconstructs object on unmarshalling.

Returns:

Reconstructed object.

Throws:

ObjectStreamException - Thrown in case of unmarshalling error.

toString

public String toString()

Overrides:

toString in class ConcurrentHashMap<K,V>