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.ClusterNodeLocalMapImplis similar toThreadLocalin a way that its values are not distributed and kept only on local node (similar likeThreadLocalvalues 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.ClusterNodeLocalMapImplis aConcurrentMapso it is trivial to use.You can get an instance of
ClusterNodeLocalMapImplby callingIgniteCluster.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>
-
-
Constructor Summary
Constructors Constructor Description ClusterNodeLocalMapImpl()No-arg constructor is required by externalization.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidreadExternal(ObjectInput in)protected ObjectreadResolve()Reconstructs object on unmarshalling.StringtoString()voidwriteExternal(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
-
-
-
-
Method Detail
-
writeExternal
public void writeExternal(ObjectOutput out) throws IOException
- Specified by:
writeExternalin interfaceExternalizable- Throws:
IOException
-
readExternal
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
- Specified by:
readExternalin interfaceExternalizable- Throws:
IOExceptionClassNotFoundException
-
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:
toStringin classConcurrentHashMap<K,V>
-
-