org.apache.ignite.internal.cluster

Class ClusterNodeLocalMapImpl<K,V>

java.lang.Object

org.jsr166.ConcurrentHashMap8<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 ConcurrentHashMap8<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 org.jsr166.ConcurrentHashMap8

ConcurrentHashMap8.Action<A>, ConcurrentHashMap8.BiAction<A,B>, ConcurrentHashMap8.BiFun<A,B,T>, ConcurrentHashMap8.DoubleByDoubleToDouble, ConcurrentHashMap8.DoubleToDouble, ConcurrentHashMap8.EntrySetView<K,V>, ConcurrentHashMap8.Fun<A,T>, ConcurrentHashMap8.Generator<T>, ConcurrentHashMap8.IntByIntToInt, ConcurrentHashMap8.IntToInt, ConcurrentHashMap8.KeySetView<K,V>, ConcurrentHashMap8.LongByLongToLong, ConcurrentHashMap8.LongToLong, ConcurrentHashMap8.ObjectByObjectToDouble<A,B>, ConcurrentHashMap8.ObjectByObjectToInt<A,B>, ConcurrentHashMap8.ObjectByObjectToLong<A,B>, ConcurrentHashMap8.ObjectToDouble<A>, ConcurrentHashMap8.ObjectToInt<A>, ConcurrentHashMap8.ObjectToLong<A>, ConcurrentHashMap8.Spliterator<T>, ConcurrentHashMap8.ValuesView<K,V>

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

Map.Entry<K,V>

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
void	readExternal(ObjectInput in)
protected Object	readResolve() Reconstructs object on unmarshalling.
String	toString() Returns a string representation of this map.
void	writeExternal(ObjectOutput out)

Methods inherited from class org.jsr166.ConcurrentHashMap8

clear, compute, computeIfAbsent, computeIfPresent, contains, containsKey, containsValue, elements, entrySet, entrySpliterator, equals, get, getValueOrDefault, hashCode, isEmpty, keys, keySet, keySet, keySpliterator, mappingCount, merge, newKeySet, newKeySet, put, putAll, putIfAbsent, remove, remove, replace, replace, size, values, valueSpliterator

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.concurrent.ConcurrentMap

putIfAbsent, remove, replace, replace

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()

Returns a string representation of this map. The string representation consists of a list of key-value mappings (in no particular order) enclosed in braces ("{}"). Adjacent mappings are separated by the characters ", " (comma and space). Each key-value mapping is rendered as the key followed by an equals sign ("=") followed by the associated value.

Overrides:

toString in class ConcurrentHashMap8<K,V>

Returns:

a string representation of this map