com.orientechnologies.orient.server.hazelcast

Class OHazelcastDistributedMap

java.lang.Object

java.util.AbstractMap<K,V>

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

com.orientechnologies.orient.server.hazelcast.OHazelcastDistributedMap

All Implemented Interfaces:

com.hazelcast.map.listener.EntryAddedListener<String,Object>, com.hazelcast.map.listener.EntryRemovedListener<String,Object>, com.hazelcast.map.listener.EntryUpdatedListener<String,Object>, com.hazelcast.map.listener.MapClearedListener, com.hazelcast.map.listener.MapListener, Serializable, ConcurrentMap<String,Object>, EventListener, Map<String,Object>

public class OHazelcastDistributedMap
extends ConcurrentHashMap<String,Object>
implements com.hazelcast.map.listener.EntryAddedListener<String,Object>, com.hazelcast.map.listener.EntryRemovedListener<String,Object>, com.hazelcast.map.listener.MapClearedListener, com.hazelcast.map.listener.EntryUpdatedListener<String,Object>

Optimized concurrent hash map implementation on top of Hazelcast distributed map.

Author:

Luca Garulli (l.garulli--at--orientechnologies.com)

See Also:

Serialized Form

Nested Class Summary

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>

Field Summary

Fields

Modifier and Type	Field and Description
static String	ORIENTDB_MAP

Constructor Summary

Constructors

Constructor and Description
OHazelcastDistributedMap(OHazelcastPlugin manager, com.hazelcast.core.HazelcastInstance hz)

Method Summary

Modifier and Type	Method and Description
void	clearLocalCache()
boolean	containsKey(Object key)
void	destroy()
void	entryAdded(com.hazelcast.core.EntryEvent<String,Object> event)
void	entryRemoved(com.hazelcast.core.EntryEvent<String,Object> event)
Set<Map.Entry<String,Object>>	entrySet()
void	entryUpdated(com.hazelcast.core.EntryEvent<String,Object> event)
Object	get(Object key)
com.hazelcast.core.IMap<String,Object>	getHazelcastMap()
Set<String>	getKeySet() In Java 8 ConcurrentHashMap.keySet() returns a KeySetView.
Object	getLocalCachedValue(Object key)
Set<Map.Entry<String,Object>>	localEntrySet()
void	mapCleared(com.hazelcast.core.MapEvent event)
Object	put(String key, Object value)
Object	putIfAbsent(String key, Object value)
Object	putInLocalCache(String key, Object value)
Object	remove(Object key)
boolean	remove(Object key, Object value)

Methods inherited from class java.util.concurrent.ConcurrentHashMap

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

Methods inherited from class java.util.AbstractMap

clone

Methods inherited from class java.lang.Object

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

Field Detail

ORIENTDB_MAP

public static final String ORIENTDB_MAP

See Also:

Constant Field Values

Constructor Detail

OHazelcastDistributedMap

public OHazelcastDistributedMap(OHazelcastPlugin manager,
                                com.hazelcast.core.HazelcastInstance hz)

Method Detail

getHazelcastMap

public com.hazelcast.core.IMap<String,Object> getHazelcastMap()

get

public Object get(Object key)

Specified by:

get in interface Map<String,Object>

Overrides:

get in class ConcurrentHashMap<String,Object>

containsKey

public boolean containsKey(Object key)

Specified by:

containsKey in interface Map<String,Object>

Overrides:

containsKey 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>

localEntrySet

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

getLocalCachedValue

public Object getLocalCachedValue(Object key)

put

public Object put(String key,
                  Object value)

Specified by:

put in interface Map<String,Object>

Overrides:

put in class ConcurrentHashMap<String,Object>

putIfAbsent

public Object putIfAbsent(String key,
                          Object value)

Specified by:

putIfAbsent in interface ConcurrentMap<String,Object>

Specified by:

putIfAbsent in interface Map<String,Object>

Overrides:

putIfAbsent in class ConcurrentHashMap<String,Object>

putInLocalCache

public Object putInLocalCache(String key,
                              Object value)

remove

public Object remove(Object key)

Specified by:

remove in interface Map<String,Object>

Overrides:

remove in class ConcurrentHashMap<String,Object>

remove

public boolean remove(Object key,
                      Object value)

Specified by:

remove in interface ConcurrentMap<String,Object>

Specified by:

remove in interface Map<String,Object>

Overrides:

remove in class ConcurrentHashMap<String,Object>

entryAdded

public void entryAdded(com.hazelcast.core.EntryEvent<String,Object> event)

Specified by:

entryAdded in interface com.hazelcast.map.listener.EntryAddedListener<String,Object>

entryUpdated

public void entryUpdated(com.hazelcast.core.EntryEvent<String,Object> event)

Specified by:

entryUpdated in interface com.hazelcast.map.listener.EntryUpdatedListener<String,Object>

entryRemoved

public void entryRemoved(com.hazelcast.core.EntryEvent<String,Object> event)

Specified by:

entryRemoved in interface com.hazelcast.map.listener.EntryRemovedListener<String,Object>

mapCleared

public void mapCleared(com.hazelcast.core.MapEvent event)

Specified by:

mapCleared in interface com.hazelcast.map.listener.MapClearedListener

destroy

public void destroy()

clearLocalCache

public void clearLocalCache()

getKeySet

public Set<String> getKeySet()

In Java 8 ConcurrentHashMap.keySet() returns a KeySetView. In Java 7 ConcurrentHashMap.keySet() returns a Set. Use this method instead of keySet() to ensure Java 7 compatibility.