com.hazelcast.map.impl.proxy

Class EnterpriseMapProxyImpl<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.EnterpriseMapProxyImpl<K,V>

Type Parameters:

K - the key type of map.

V - the value type of map.

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 EnterpriseMapProxyImpl<K,V>
extends com.hazelcast.map.impl.proxy.MapProxyImpl<K,V>
implements IEnterpriseMap<K,V>

Proxy implementation of IMap interface which includes enterprise version specific extensions.

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
EnterpriseMapProxyImpl(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 boolean	containsKeyInternal(Object arg0)
protected Iterable<com.hazelcast.nio.serialization.Data>	convertToData(Iterable<K> arg0)
protected void	deleteInternal(Object arg0)
protected void	evictAllInternal()
protected boolean	evictInternal(Object 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 void	finalizePutAll(Map<?,?> arg0)
protected void	getAllInternal(Set<K> arg0, List<com.hazelcast.nio.serialization.Data> arg1, List<Object> arg2)
protected com.hazelcast.spi.InternalCompletableFuture<com.hazelcast.nio.serialization.Data>	getAsyncInternal(Object arg0)
protected com.hazelcast.core.EntryView	getEntryViewInternal(com.hazelcast.nio.serialization.Data arg0)
protected Object	getInternal(Object arg0)
protected com.hazelcast.map.impl.query.QueryEngine	getMapQueryEngine()
String	getName()
String	getServiceName()
protected void	handleHazelcastInstanceAwareParams(Object... arg0)
protected void	incrementOtherOperationsStat()
protected void	invokePutAllOperationFactory(long arg0, int[] arg1, com.hazelcast.map.impl.MapEntries[] arg2)
protected boolean	isMapStoreEnabled()
protected void	loadAllInternal(boolean arg0)
protected void	loadInternal(Set<K> arg0, Iterable<com.hazelcast.nio.serialization.Data> arg1, boolean arg2)
protected boolean	preDestroy()
protected void	putAllInternal(Map<?,?> arg0)
protected com.hazelcast.spi.InternalCompletableFuture<com.hazelcast.nio.serialization.Data>	putAsyncInternal(Object arg0, com.hazelcast.nio.serialization.Data arg1, long arg2, TimeUnit arg3, long arg4, TimeUnit arg5)
protected com.hazelcast.nio.serialization.Data	putIfAbsentInternal(Object arg0, com.hazelcast.nio.serialization.Data arg1, long arg2, TimeUnit arg3, long arg4, TimeUnit arg5)
protected com.hazelcast.nio.serialization.Data	putInternal(Object arg0, com.hazelcast.nio.serialization.Data arg1, long arg2, TimeUnit arg3, long arg4, TimeUnit arg5)
protected void	putTransientInternal(Object arg0, com.hazelcast.nio.serialization.Data arg1, long arg2, TimeUnit arg3, long arg4, TimeUnit arg5)
protected void	removeAllInternal(com.hazelcast.query.Predicate arg0)
protected com.hazelcast.spi.InternalCompletableFuture<com.hazelcast.nio.serialization.Data>	removeAsyncInternal(Object arg0)
protected boolean	removeEntryListenerInternal(String arg0)
protected com.hazelcast.nio.serialization.Data	removeInternal(Object arg0)
protected boolean	removeInternal(Object arg0, com.hazelcast.nio.serialization.Data arg1)
protected boolean	removePartitionLostListenerInternal(String arg0)
protected com.hazelcast.nio.serialization.Data	replaceInternal(Object arg0, com.hazelcast.nio.serialization.Data arg1)
protected boolean	replaceInternal(Object arg0, com.hazelcast.nio.serialization.Data arg1, com.hazelcast.nio.serialization.Data arg2)
protected com.hazelcast.spi.InternalCompletableFuture<com.hazelcast.nio.serialization.Data>	setAsyncInternal(Object arg0, com.hazelcast.nio.serialization.Data arg1, long arg2, TimeUnit arg3, long arg4, TimeUnit arg5)
protected void	setInternal(Object arg0, com.hazelcast.nio.serialization.Data arg1, long arg2, TimeUnit arg3, long arg4, TimeUnit arg5)
protected boolean	setTtlInternal(Object arg0, long arg1, TimeUnit arg2)
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)
protected boolean	tryPutInternal(Object arg0, com.hazelcast.nio.serialization.Data arg1, long arg2, TimeUnit arg3)
protected boolean	tryRemoveInternal(Object arg0, long arg1, TimeUnit arg2)

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, postDestroy, 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

EnterpriseMapProxyImpl

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

getInternal

protected Object getInternal(Object arg0)

getAsyncInternal

protected com.hazelcast.spi.InternalCompletableFuture<com.hazelcast.nio.serialization.Data> getAsyncInternal(Object arg0)

putInternal

protected com.hazelcast.nio.serialization.Data putInternal(Object arg0,
                                                           com.hazelcast.nio.serialization.Data arg1,
                                                           long arg2,
                                                           TimeUnit arg3,
                                                           long arg4,
                                                           TimeUnit arg5)

tryPutInternal

protected boolean tryPutInternal(Object arg0,
                                 com.hazelcast.nio.serialization.Data arg1,
                                 long arg2,
                                 TimeUnit arg3)

putIfAbsentInternal

protected com.hazelcast.nio.serialization.Data putIfAbsentInternal(Object arg0,
                                                                   com.hazelcast.nio.serialization.Data arg1,
                                                                   long arg2,
                                                                   TimeUnit arg3,
                                                                   long arg4,
                                                                   TimeUnit arg5)

putTransientInternal

protected void putTransientInternal(Object arg0,
                                    com.hazelcast.nio.serialization.Data arg1,
                                    long arg2,
                                    TimeUnit arg3,
                                    long arg4,
                                    TimeUnit arg5)

putAsyncInternal

protected com.hazelcast.spi.InternalCompletableFuture<com.hazelcast.nio.serialization.Data> putAsyncInternal(Object arg0,
                                                                                                             com.hazelcast.nio.serialization.Data arg1,
                                                                                                             long arg2,
                                                                                                             TimeUnit arg3,
                                                                                                             long arg4,
                                                                                                             TimeUnit arg5)

setAsyncInternal

protected com.hazelcast.spi.InternalCompletableFuture<com.hazelcast.nio.serialization.Data> setAsyncInternal(Object arg0,
                                                                                                             com.hazelcast.nio.serialization.Data arg1,
                                                                                                             long arg2,
                                                                                                             TimeUnit arg3,
                                                                                                             long arg4,
                                                                                                             TimeUnit arg5)

replaceInternal

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

replaceInternal

protected com.hazelcast.nio.serialization.Data replaceInternal(Object arg0,
                                                               com.hazelcast.nio.serialization.Data arg1)

setInternal

protected void setInternal(Object arg0,
                           com.hazelcast.nio.serialization.Data arg1,
                           long arg2,
                           TimeUnit arg3,
                           long arg4,
                           TimeUnit arg5)

evictInternal

protected boolean evictInternal(Object arg0)

evictAllInternal

protected void evictAllInternal()

loadAllInternal

protected void loadAllInternal(boolean arg0)

loadInternal

protected void loadInternal(Set<K> arg0,
                            Iterable<com.hazelcast.nio.serialization.Data> arg1,
                            boolean arg2)

convertToData

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

removeInternal

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

deleteInternal

protected void deleteInternal(Object arg0)

removeInternal

protected boolean removeInternal(Object arg0,
                                 com.hazelcast.nio.serialization.Data arg1)

tryRemoveInternal

protected boolean tryRemoveInternal(Object arg0,
                                    long arg1,
                                    TimeUnit arg2)

removeAllInternal

protected void removeAllInternal(com.hazelcast.query.Predicate arg0)

setTtlInternal

protected boolean setTtlInternal(Object arg0,
                                 long arg1,
                                 TimeUnit arg2)

removeAsyncInternal

protected com.hazelcast.spi.InternalCompletableFuture<com.hazelcast.nio.serialization.Data> removeAsyncInternal(Object arg0)

containsKeyInternal

protected boolean containsKeyInternal(Object arg0)

incrementOtherOperationsStat

protected void incrementOtherOperationsStat()

getAllInternal

protected void getAllInternal(Set<K> arg0,
                              List<com.hazelcast.nio.serialization.Data> arg1,
                              List<Object> arg2)

putAllInternal

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

invokePutAllOperationFactory

protected void invokePutAllOperationFactory(long arg0,
                                            int[] arg1,
                                            com.hazelcast.map.impl.MapEntries[] arg2)
                                     throws Exception

Throws:

Exception

finalizePutAll

protected void finalizePutAll(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)