Package 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--orientdb.com)

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>

Field Summary

Fields

Modifier and Type	Field	Description
static final String	ORIENTDB_MAP

Constructor Summary

Constructors

Constructor	Description
OHazelcastDistributedMap(com.hazelcast.core.HazelcastInstance hz)

Method Summary

Modifier and Type	Method	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)
boolean	existsDatabaseConfiguration(String databaseName)
boolean	existsNode(String nodeUuid)
Object	get(Object key)
ODistributedServerManager.DB_STATUS	getCachedDatabaseStatus(String node, String databaseName)
ODocument	getDatabaseConfiguration(String databaseName)
Set<String>	getDatabases()
ODistributedServerManager.DB_STATUS	getDatabaseStatus(String node, String databaseName)
static String	getDatabaseStatusKeyValues(String key)
com.hazelcast.core.IMap<String,Object>	getHazelcastMap()
ONodeConfig	getLocalCachedNodeConfig(String nodeUuid)
Object	getLocalCachedValue(Object key)
ONodeConfig	getNodeConfig(String nodeUuid)
List<String>	getNodes()
Set<String>	getNodeUuidByName(String name)
ORegisteredNodes	getRegisteredNodes()
static boolean	isDatabaseConfiguration(String key)
static boolean	isDatabaseStatus(String key)
static boolean	isNodeConfigKey(String key)
static boolean	isRegisteredNodes(String 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)
void	putNodeConfig(String nodeUuid, ONodeConfig cfg)
void	putRegisteredNodes(ORegisteredNodes registeredNodes)
Object	remove(Object key)
boolean	remove(Object key, Object value)
void	removeDatabaseConfiguration(String databaseName)
void	removeDatabaseStatus(String node, String databaseName)
void	removeNode(String nodeUuid)
void	setDatabaseConfiguration(String databaseName, ODocument document)
void	setDatabaseStatus(String node, String databaseName, ODistributedServerManager.DB_STATUS status)

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 Details

ORIENTDB_MAP

public static final String ORIENTDB_MAP

See Also:

• Constant Field Values

Constructor Details

OHazelcastDistributedMap

public OHazelcastDistributedMap(com.hazelcast.core.HazelcastInstance hz)

Method Details

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

existsNode

public boolean existsNode(String nodeUuid)

getNodeConfig

public ONodeConfig getNodeConfig(String nodeUuid)

removeNode

public void removeNode(String nodeUuid)

getLocalCachedNodeConfig

public ONodeConfig getLocalCachedNodeConfig(String nodeUuid)

getNodes

public List<String> getNodes()

putNodeConfig

public void putNodeConfig(String nodeUuid,
 ONodeConfig cfg)

getNodeUuidByName

public Set<String> getNodeUuidByName(String name)

isNodeConfigKey

public static boolean isNodeConfigKey(String key)

getRegisteredNodes

public ORegisteredNodes getRegisteredNodes()

putRegisteredNodes

public void putRegisteredNodes(ORegisteredNodes registeredNodes)

isRegisteredNodes

public static boolean isRegisteredNodes(String key)

existsDatabaseConfiguration

public boolean existsDatabaseConfiguration(String databaseName)

setDatabaseConfiguration

public void setDatabaseConfiguration(String databaseName,
 ODocument document)

getDatabaseConfiguration

public ODocument getDatabaseConfiguration(String databaseName)

getDatabases

public Set<String> getDatabases()

removeDatabaseConfiguration

public void removeDatabaseConfiguration(String databaseName)

isDatabaseConfiguration

public static boolean isDatabaseConfiguration(String key)

setDatabaseStatus

public void setDatabaseStatus(String node,
 String databaseName,
 ODistributedServerManager.DB_STATUS status)

removeDatabaseStatus

public void removeDatabaseStatus(String node,
 String databaseName)

getDatabaseStatus

public ODistributedServerManager.DB_STATUS getDatabaseStatus(String node,
 String databaseName)

getCachedDatabaseStatus

public ODistributedServerManager.DB_STATUS getCachedDatabaseStatus(String node,
 String databaseName)

isDatabaseStatus

public static boolean isDatabaseStatus(String key)

getDatabaseStatusKeyValues

public static String getDatabaseStatusKeyValues(String key)