com.hazelcast.map.impl.proxy

Class EnterpriseNearCachedMapProxyImpl<K,V>

java.lang.Object

com.hazelcast.spi.AbstractDistributedObject<com.hazelcast.map.impl.MapService>

com.hazelcast.map.impl.proxy.MapProxyImpl<K,V>

com.hazelcast.map.impl.proxy.NearCachedMapProxyImpl<K,V>

com.hazelcast.map.impl.proxy.EnterpriseNearCachedMapProxyImpl<K,V>

Type Parameters:

K - the key type for this IMap proxy.

V - the value type for this IMap proxy.

All Implemented Interfaces:

com.hazelcast.core.BaseMap<K,V>, com.hazelcast.core.DistributedObject, IEnterpriseMap<K,V>, com.hazelcast.core.IMap<K,V>, com.hazelcast.internal.journal.EventJournalReader<com.hazelcast.map.journal.EventJournalMapEvent<K,V>>, com.hazelcast.map.impl.LegacyAsyncMap<K,V>, com.hazelcast.spi.InitializingObject, ConcurrentMap<K,V>, Map<K,V>

public class EnterpriseNearCachedMapProxyImpl<K,V>
extends com.hazelcast.map.impl.proxy.NearCachedMapProxyImpl<K,V>
implements IEnterpriseMap<K,V>

A server-side IEnterpriseMap implementation which is fronted by a Near Cache.

Nested Class Summary

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

Map.Entry<K,V>

Field Summary

Fields

Modifier and Type	Field and Description
protected com.hazelcast.monitor.impl.LocalMapStatsImpl	localMapStats
protected com.hazelcast.concurrent.lock.LockProxySupport	lockSupport
protected com.hazelcast.config.MapConfig	mapConfig
protected com.hazelcast.map.impl.MapServiceContext	mapServiceContext
protected String	name
protected static String	NULL_AGGREGATOR_IS_NOT_ALLOWED
protected static String	NULL_KEY_IS_NOT_ALLOWED
protected static String	NULL_KEYS_ARE_NOT_ALLOWED
protected static String	NULL_LISTENER_IS_NOT_ALLOWED
protected static String	NULL_PREDICATE_IS_NOT_ALLOWED
protected static String	NULL_PROJECTION_IS_NOT_ALLOWED
protected static String	NULL_VALUE_IS_NOT_ALLOWED
protected com.hazelcast.map.impl.operation.MapOperationProvider	operationProvider
protected com.hazelcast.spi.OperationService	operationService
protected com.hazelcast.spi.partition.IPartitionService	partitionService
protected com.hazelcast.core.PartitioningStrategy	partitionStrategy
protected com.hazelcast.spi.serialization.SerializationService	serializationService
protected boolean	statisticsEnabled
protected com.hazelcast.nio.Address	thisAddress

Fields inherited from class com.hazelcast.spi.AbstractDistributedObject

PARTITIONING_STRATEGY

Constructor Summary

Constructors

Constructor and Description
EnterpriseNearCachedMapProxyImpl(String name, com.hazelcast.map.impl.MapService mapService, com.hazelcast.spi.NodeEngine nodeEngine, com.hazelcast.config.MapConfig mapConfig)

Method Summary

Modifier and Type	Method and Description
protected String	addEntryListenerInternal(Object arg0, com.hazelcast.nio.serialization.Data arg1, boolean arg2)
protected String	addEntryListenerInternal(Object arg0, com.hazelcast.query.Predicate arg1, com.hazelcast.nio.serialization.Data arg2, boolean arg3)
protected String	addPartitionLostListenerInternal(com.hazelcast.map.listener.MapPartitionLostListener arg0)
protected Iterable<com.hazelcast.nio.serialization.Data>	convertToData(Iterable<K> arg0)
protected <T extends com.hazelcast.map.impl.query.Result> T	executeQueryInternal(com.hazelcast.query.Predicate arg0, com.hazelcast.aggregation.Aggregator arg1, com.hazelcast.projection.Projection arg2, com.hazelcast.util.IterationType arg3, com.hazelcast.map.impl.query.Target arg4)
protected <T extends com.hazelcast.map.impl.query.Result> T	executeQueryInternal(com.hazelcast.query.Predicate arg0, com.hazelcast.util.IterationType arg1, com.hazelcast.map.impl.query.Target arg2)
protected com.hazelcast.core.EntryView	getEntryViewInternal(com.hazelcast.nio.serialization.Data arg0)
protected com.hazelcast.map.impl.query.QueryEngine	getMapQueryEngine()
String	getName()
String	getServiceName()
protected void	handleHazelcastInstanceAwareParams(Object... arg0)
protected void	incrementOtherOperationsStat()
protected boolean	isMapStoreEnabled()
protected boolean	preDestroy()
protected void	putAllInternal(Map<?,?> arg0)
protected boolean	removeEntryListenerInternal(String arg0)
protected boolean	removePartitionLostListenerInternal(String arg0)
protected com.hazelcast.nio.serialization.Data	toData(Object arg0, com.hazelcast.core.PartitioningStrategy arg1)
protected void	toDataCollectionWithNonNullKeyValidation(Set<K> arg0, Collection<com.hazelcast.nio.serialization.Data> arg1)
protected com.hazelcast.nio.serialization.Data	toDataWithStrategy(Object arg0)
protected <T> T	toObject(Object arg0)

Methods inherited from class com.hazelcast.map.impl.proxy.NearCachedMapProxyImpl

addNearCacheInvalidationListener, clearInternal, containsKeyInternal, deleteInternal, evictAllInternal, evictInternal, executeOnEntriesInternal, executeOnKeyInternal, executeOnKeyInternal, finalizePutAll, getAllInternal, getAsyncInternal, getInternal, getNearCache, initialize, invalidateNearCache, invokePutAllOperationFactory, loadAllInternal, loadInternal, postDestroy, putAsyncInternal, putIfAbsentInternal, putInternal, putTransientInternal, removeAllInternal, removeAsyncInternal, removeInternal, removeInternal, replaceInternal, replaceInternal, setAsyncInternal, setInternal, setTtlInternal, submitToKeysInternal, tryPutInternal, tryRemoveInternal

Methods inherited from class com.hazelcast.map.impl.proxy.MapProxyImpl

addEntryListener, addEntryListener, addEntryListener, addEntryListener, addEntryListener, addEntryListener, addEntryListener, addEntryListener, addInterceptor, addLocalEntryListener, addLocalEntryListener, addLocalEntryListener, addLocalEntryListener, addLocalEntryListener, addLocalEntryListener, addPartitionLostListener, aggregate, aggregate, aggregate, aggregate, clear, containsKey, containsValue, delete, entrySet, entrySet, evict, evictAll, executeOnEntries, executeOnEntries, executeOnKey, executeOnKeys, forceUnlock, get, getAll, getAsync, getEntryView, getQueryCache, getQueryCache, getQueryCache, invoke, isLocked, iterator, iterator, keySet, keySet, loadAll, loadAll, localKeySet, localKeySet, lock, lock, project, project, put, put, put, putAll, putAsync, putAsync, putAsync, putIfAbsent, putIfAbsent, putIfAbsent, putTransient, putTransient, readFromEventJournal, remove, remove, removeAll, removeAsync, removeEntryListener, removeInterceptor, removePartitionLostListener, replace, replace, set, set, set, setAsync, setAsync, setAsync, setTtl, submitToKey, submitToKey, submitToKeys, subscribeToEventJournal, toString, tryLock, tryLock, tryLock, tryPut, tryRemove, unlock, values, values

Methods inherited from class com.hazelcast.spi.AbstractDistributedObject

destroy, equals, getDistributedObjectName, getNameAsPartitionAwareData, getNodeEngine, getOperationService, getPartitionId, getPartitionKey, getService, hashCode, invalidate, invokeOnPartition, isClusterVersionEqualTo, isClusterVersionGreaterOrEqual, isClusterVersionGreaterThan, isClusterVersionLessOrEqual, isClusterVersionLessThan, isClusterVersionUnknown, isClusterVersionUnknownOrGreaterOrEqual, isClusterVersionUnknownOrGreaterThan, isClusterVersionUnknownOrLessOrEqual, isClusterVersionUnknownOrLessThan, throwNotActiveException, toData

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.hazelcast.core.IMap

addEntryListener, addEntryListener, addEntryListener, addEntryListener, addEntryListener, addEntryListener, addEntryListener, addEntryListener, addIndex, addInterceptor, addLocalEntryListener, addLocalEntryListener, addLocalEntryListener, addLocalEntryListener, addLocalEntryListener, addLocalEntryListener, addPartitionLostListener, aggregate, aggregate, aggregate, aggregate, clear, containsKey, containsValue, delete, entrySet, entrySet, evict, evictAll, executeOnEntries, executeOnEntries, executeOnKey, executeOnKeys, flush, forceUnlock, get, getAll, getAsync, getEntryView, getLocalMapStats, getQueryCache, getQueryCache, getQueryCache, isLocked, keySet, keySet, loadAll, loadAll, localKeySet, localKeySet, lock, lock, project, project, put, put, put, putAll, putAsync, putAsync, putAsync, putIfAbsent, putIfAbsent, putIfAbsent, putTransient, putTransient, remove, remove, removeAll, removeAsync, removeEntryListener, removeInterceptor, removePartitionLostListener, replace, replace, set, set, set, setAsync, setAsync, setAsync, setTtl, submitToKey, submitToKey, tryLock, tryLock, tryLock, tryPut, tryRemove, unlock, values, values

Methods inherited from interface java.util.concurrent.ConcurrentMap

compute, computeIfAbsent, computeIfPresent, forEach, getOrDefault, merge, replaceAll

Methods inherited from interface java.util.Map

equals, hashCode, isEmpty, size

Methods inherited from interface com.hazelcast.core.BaseMap

isEmpty, size

Methods inherited from interface com.hazelcast.core.DistributedObject

destroy, getName, getPartitionKey, getServiceName

Field Detail

NULL_KEY_IS_NOT_ALLOWED

protected static final String NULL_KEY_IS_NOT_ALLOWED

See Also:

Constant Field Values

NULL_KEYS_ARE_NOT_ALLOWED

protected static final String NULL_KEYS_ARE_NOT_ALLOWED

See Also:

Constant Field Values

NULL_VALUE_IS_NOT_ALLOWED

protected static final String NULL_VALUE_IS_NOT_ALLOWED

See Also:

Constant Field Values

NULL_PREDICATE_IS_NOT_ALLOWED

protected static final String NULL_PREDICATE_IS_NOT_ALLOWED

See Also:

Constant Field Values

NULL_LISTENER_IS_NOT_ALLOWED

protected static final String NULL_LISTENER_IS_NOT_ALLOWED

See Also:

Constant Field Values

NULL_AGGREGATOR_IS_NOT_ALLOWED

protected static final String NULL_AGGREGATOR_IS_NOT_ALLOWED

See Also:

Constant Field Values

NULL_PROJECTION_IS_NOT_ALLOWED

protected static final String NULL_PROJECTION_IS_NOT_ALLOWED

See Also:

Constant Field Values

name

protected final String name

localMapStats

protected final com.hazelcast.monitor.impl.LocalMapStatsImpl localMapStats

lockSupport

protected final com.hazelcast.concurrent.lock.LockProxySupport lockSupport

partitionStrategy

protected final com.hazelcast.core.PartitioningStrategy partitionStrategy

mapServiceContext

protected final com.hazelcast.map.impl.MapServiceContext mapServiceContext

partitionService

protected final com.hazelcast.spi.partition.IPartitionService partitionService

thisAddress

protected final com.hazelcast.nio.Address thisAddress

operationService

protected final com.hazelcast.spi.OperationService operationService

serializationService

protected final com.hazelcast.spi.serialization.SerializationService serializationService

statisticsEnabled

protected final boolean statisticsEnabled

mapConfig

protected final com.hazelcast.config.MapConfig mapConfig

operationProvider

protected com.hazelcast.map.impl.operation.MapOperationProvider operationProvider

Constructor Detail

EnterpriseNearCachedMapProxyImpl

public EnterpriseNearCachedMapProxyImpl(String name,
                                        com.hazelcast.map.impl.MapService mapService,
                                        com.hazelcast.spi.NodeEngine nodeEngine,
                                        com.hazelcast.config.MapConfig mapConfig)

Method Detail

getName

public final String getName()

Specified by:

getName in interface com.hazelcast.core.DistributedObject

getServiceName

public final String getServiceName()

Specified by:

getServiceName in interface com.hazelcast.core.DistributedObject

Specified by:

getServiceName in class com.hazelcast.spi.AbstractDistributedObject<com.hazelcast.map.impl.MapService>

getMapQueryEngine

protected com.hazelcast.map.impl.query.QueryEngine getMapQueryEngine()

isMapStoreEnabled

protected boolean isMapStoreEnabled()

convertToData

protected Iterable<com.hazelcast.nio.serialization.Data> convertToData(Iterable<K> arg0)

incrementOtherOperationsStat

protected void incrementOtherOperationsStat()

putAllInternal

protected void putAllInternal(Map<?,?> arg0)

addEntryListenerInternal

protected String addEntryListenerInternal(Object arg0,
                                          com.hazelcast.nio.serialization.Data arg1,
                                          boolean arg2)

addEntryListenerInternal

protected String addEntryListenerInternal(Object arg0,
                                          com.hazelcast.query.Predicate arg1,
                                          com.hazelcast.nio.serialization.Data arg2,
                                          boolean arg3)

removeEntryListenerInternal

protected boolean removeEntryListenerInternal(String arg0)

addPartitionLostListenerInternal

protected String addPartitionLostListenerInternal(com.hazelcast.map.listener.MapPartitionLostListener arg0)

removePartitionLostListenerInternal

protected boolean removePartitionLostListenerInternal(String arg0)

getEntryViewInternal

protected com.hazelcast.core.EntryView getEntryViewInternal(com.hazelcast.nio.serialization.Data arg0)

toObject

protected <T> T toObject(Object arg0)

toDataWithStrategy

protected com.hazelcast.nio.serialization.Data toDataWithStrategy(Object arg0)

toData

protected com.hazelcast.nio.serialization.Data toData(Object arg0,
                                                      com.hazelcast.core.PartitioningStrategy arg1)

preDestroy

protected boolean preDestroy()

Overrides:

preDestroy in class com.hazelcast.spi.AbstractDistributedObject<com.hazelcast.map.impl.MapService>

toDataCollectionWithNonNullKeyValidation

protected void toDataCollectionWithNonNullKeyValidation(Set<K> arg0,
                                                        Collection<com.hazelcast.nio.serialization.Data> arg1)

executeQueryInternal

protected <T extends com.hazelcast.map.impl.query.Result> T executeQueryInternal(com.hazelcast.query.Predicate arg0,
                                                                                 com.hazelcast.util.IterationType arg1,
                                                                                 com.hazelcast.map.impl.query.Target arg2)

executeQueryInternal

protected <T extends com.hazelcast.map.impl.query.Result> T executeQueryInternal(com.hazelcast.query.Predicate arg0,
                                                                                 com.hazelcast.aggregation.Aggregator arg1,
                                                                                 com.hazelcast.projection.Projection arg2,
                                                                                 com.hazelcast.util.IterationType arg3,
                                                                                 com.hazelcast.map.impl.query.Target arg4)

handleHazelcastInstanceAwareParams

protected void handleHazelcastInstanceAwareParams(Object... arg0)