com.hazelcast.map.impl.proxy

Class NearCachedMapProxyImpl<K,V>

java.lang.Object

com.hazelcast.spi.AbstractDistributedObject<MapService>

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

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

Type Parameters:

K - the key type for this IMap proxy.

V - the value type for this IMap proxy.

All Implemented Interfaces:

BaseMap<K,V>, DistributedObject, IMap<K,V>, LegacyAsyncMap<K,V>, InitializingObject, ConcurrentMap<K,V>, Map<K,V>

public class NearCachedMapProxyImpl<K,V>
extends MapProxyImpl<K,V>

A server-side IMap 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 LocalMapStatsImpl	localMapStats
protected String	localMemberUuid
protected LockProxySupport	lockSupport
protected MapConfig	mapConfig
protected 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_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 MapOperationProvider	operationProvider
protected OperationService	operationService
protected IPartitionService	partitionService
protected PartitioningStrategy	partitionStrategy
protected SerializationService	serializationService
protected boolean	statisticsEnabled
protected Address	thisAddress

Fields inherited from class com.hazelcast.spi.AbstractDistributedObject

PARTITIONING_STRATEGY

Constructor Summary

Constructors

Constructor and Description
NearCachedMapProxyImpl(String name, MapService mapService, NodeEngine nodeEngine, MapConfig mapConfig)

Method Summary

Modifier and Type	Method and Description
protected String	addEntryListenerInternal(Object listener, Data key, boolean includeValue)
protected String	addEntryListenerInternal(Object listener, Predicate predicate, Data key, boolean includeValue)
void	addIndex(String attribute, boolean ordered)
String	addLocalEntryListenerInternal(Object listener)
String	addLocalEntryListenerInternal(Object listener, Predicate predicate, Data key, boolean includeValue)
String	addMapInterceptorInternal(MapInterceptor interceptor)
protected String	addPartitionLostListenerInternal(MapPartitionLostListener listener)
void	clearInternal()
protected boolean	containsKeyInternal(Data keyData)
boolean	containsValueInternal(Data dataValue)
protected <K> Iterable<Data>	convertToData(Iterable<K> keys)
protected void	deleteInternal(Data key)
protected void	evictAllInternal()
protected boolean	evictInternal(Data key) Evicts a key from a map.
void	executeOnEntriesInternal(EntryProcessor entryProcessor, Predicate predicate, List<Data> resultingKeyValuePairs) IMap.executeOnEntries(EntryProcessor, Predicate)
Data	executeOnKeyInternal(Data key, EntryProcessor entryProcessor)
InternalCompletableFuture<Object>	executeOnKeyInternal(Data key, EntryProcessor entryProcessor, ExecutionCallback<Object> callback)
Map	executeOnKeysInternal(Set<Data> keys, EntryProcessor entryProcessor)
void	flush()
protected void	getAllObjectInternal(List<Data> keys, List<Object> resultingKeyValuePairs)
protected InternalCompletableFuture<Data>	getAsyncInternal(Data key)
protected EntryView	getEntryViewInternal(Data key)
protected Object	getInternal(Data key)
LocalMapStats	getLocalMapStats()
protected MapConfig	getMapConfig()
protected MapQueryEngine	getMapQueryEngine()
String	getName() Returns the unique name for this DistributedObject.
NearCache<Object,Object>	getNearCache()
MapOperationProvider	getOperationProvider()
PartitioningStrategy	getPartitionStrategy()
String	getServiceName() Returns the service name for this object.
protected long	getTimeInMillis(long time, TimeUnit timeunit)
int	getTotalBackupCount()
void	initialize()
protected void	invalidateCache(Collection<Data> keys)
protected void	invalidateCache(Data key)
protected void	invalidateCache(Iterable<Data> keys)
protected void	invokePutAllOperationFactory(Address address, long size, int[] partitions, MapEntries[] entries)
boolean	isEmpty()
protected boolean	isMapStoreEnabled()
protected boolean	isOwn(Data key)
void	loadAllInternal(boolean replaceExistingValues)
protected void	loadInternal(Iterable<Data> keys, boolean replaceExistingValues) Maps keys to corresponding partitions and sends operations to them.
protected boolean	preDestroy()
protected void	putAllInternal(Map<?,?> map) This method will group all puts per partition and send a PutAllPartitionAwareOperationFactory per member.
protected InternalCompletableFuture<Data>	putAsyncInternal(Data key, Data value, long ttl, TimeUnit timeunit)
protected Data	putIfAbsentInternal(Data key, Data value, long ttl, TimeUnit timeunit)
protected Data	putInternal(Data key, Data value, long ttl, TimeUnit timeunit)
protected void	putTransientInternal(Data key, Data value, long ttl, TimeUnit timeunit)
protected void	removeAllInternal(Predicate predicate)
protected InternalCompletableFuture<Data>	removeAsyncInternal(Data key)
protected boolean	removeEntryListenerInternal(String id)
protected Data	removeInternal(Data key)
protected boolean	removeInternal(Data key, Data value)
void	removeMapInterceptorInternal(String id)
protected boolean	removePartitionLostListenerInternal(String id)
protected Data	replaceInternal(Data key, Data value)
protected boolean	replaceInternal(Data key, Data expect, Data update)
protected InternalCompletableFuture<Data>	setAsyncInternal(Data key, Data value, long ttl, TimeUnit timeunit)
protected void	setInternal(Data key, Data value, long ttl, TimeUnit timeunit)
void	setOperationProvider(MapOperationProvider operationProvider)
int	size()
protected Data	toData(Object object, PartitioningStrategy partitioningStrategy)
protected <T> T	toObject(Object object)
protected boolean	tryPutInternal(Data key, Data value, long timeout, TimeUnit timeunit)
protected boolean	tryRemoveInternal(Data key, long timeout, TimeUnit timeunit)
void	waitUntilLoaded()

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, clearMapOnly, containsKey, containsValue, delete, entrySet, entrySet, evict, evictAll, executeOnEntries, executeOnEntries, executeOnKey, executeOnKeys, forceUnlock, get, getAll, getAsync, getEntryView, getQueryCache, getQueryCache, getQueryCache, invoke, isLocked, iterator, keySet, keySet, loadAll, loadAll, localKeySet, localKeySet, lock, lock, project, project, put, put, putAll, putAsync, putAsync, putIfAbsent, putIfAbsent, putTransient, remove, remove, removeAll, removeAsync, removeEntryListener, removeInterceptor, removePartitionLostListener, replace, replace, set, set, setAsync, setAsync, submitToKey, submitToKey, 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, 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

addIndex, flush, getLocalMapStats

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_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 LocalMapStatsImpl localMapStats

lockSupport

protected final LockProxySupport lockSupport

partitionStrategy

protected final PartitioningStrategy partitionStrategy

mapServiceContext

protected final MapServiceContext mapServiceContext

partitionService

protected final IPartitionService partitionService

thisAddress

protected final Address thisAddress

operationService

protected final OperationService operationService

serializationService

protected final SerializationService serializationService

statisticsEnabled

protected final boolean statisticsEnabled

mapConfig

protected final MapConfig mapConfig

localMemberUuid

protected final String localMemberUuid

operationProvider

protected MapOperationProvider operationProvider

Constructor Detail

NearCachedMapProxyImpl

public NearCachedMapProxyImpl(String name,
                              MapService mapService,
                              NodeEngine nodeEngine,
                              MapConfig mapConfig)

Method Detail

initialize

public void initialize()

Specified by:

initialize in interface InitializingObject

getInternal

protected Object getInternal(Data key)

getAsyncInternal

protected InternalCompletableFuture<Data> getAsyncInternal(Data key)

putInternal

protected Data putInternal(Data key,
                           Data value,
                           long ttl,
                           TimeUnit timeunit)

tryPutInternal

protected boolean tryPutInternal(Data key,
                                 Data value,
                                 long timeout,
                                 TimeUnit timeunit)

putIfAbsentInternal

protected Data putIfAbsentInternal(Data key,
                                   Data value,
                                   long ttl,
                                   TimeUnit timeunit)

putTransientInternal

protected void putTransientInternal(Data key,
                                    Data value,
                                    long ttl,
                                    TimeUnit timeunit)

putAsyncInternal

protected InternalCompletableFuture<Data> putAsyncInternal(Data key,
                                                           Data value,
                                                           long ttl,
                                                           TimeUnit timeunit)

setAsyncInternal

protected InternalCompletableFuture<Data> setAsyncInternal(Data key,
                                                           Data value,
                                                           long ttl,
                                                           TimeUnit timeunit)

replaceInternal

protected boolean replaceInternal(Data key,
                                  Data expect,
                                  Data update)

replaceInternal

protected Data replaceInternal(Data key,
                               Data value)

setInternal

protected void setInternal(Data key,
                           Data value,
                           long ttl,
                           TimeUnit timeunit)

evictInternal

protected boolean evictInternal(Data key)

Evicts a key from a map.

Parameters:

key - the key to evict

Returns:

true if eviction was successful, false otherwise

evictAllInternal

protected void evictAllInternal()

clearInternal

public void clearInternal()

loadAllInternal

public void loadAllInternal(boolean replaceExistingValues)

loadInternal

protected void loadInternal(Iterable<Data> keys,
                            boolean replaceExistingValues)

Maps keys to corresponding partitions and sends operations to them.

removeInternal

protected Data removeInternal(Data key)

removeAllInternal

protected void removeAllInternal(Predicate predicate)

deleteInternal

protected void deleteInternal(Data key)

removeInternal

protected boolean removeInternal(Data key,
                                 Data value)

tryRemoveInternal

protected boolean tryRemoveInternal(Data key,
                                    long timeout,
                                    TimeUnit timeunit)

removeAsyncInternal

protected InternalCompletableFuture<Data> removeAsyncInternal(Data key)

containsKeyInternal

protected boolean containsKeyInternal(Data keyData)

getAllObjectInternal

protected void getAllObjectInternal(List<Data> keys,
                                    List<Object> resultingKeyValuePairs)

invokePutAllOperationFactory

protected void invokePutAllOperationFactory(Address address,
                                            long size,
                                            int[] partitions,
                                            MapEntries[] entries)
                                     throws Exception

Throws:

Exception

executeOnKeyInternal

public Data executeOnKeyInternal(Data key,
                                 EntryProcessor entryProcessor)

executeOnKeysInternal

public Map executeOnKeysInternal(Set<Data> keys,
                                 EntryProcessor entryProcessor)

executeOnKeyInternal

public InternalCompletableFuture<Object> executeOnKeyInternal(Data key,
                                                              EntryProcessor entryProcessor,
                                                              ExecutionCallback<Object> callback)

executeOnEntriesInternal

public void executeOnEntriesInternal(EntryProcessor entryProcessor,
                                     Predicate predicate,
                                     List<Data> resultingKeyValuePairs)

IMap.executeOnEntries(EntryProcessor, Predicate)

preDestroy

protected boolean preDestroy()

Overrides:

preDestroy in class AbstractDistributedObject<MapService>

invalidateCache

protected void invalidateCache(Data key)

invalidateCache

protected void invalidateCache(Collection<Data> keys)

invalidateCache

protected void invalidateCache(Iterable<Data> keys)

isOwn

protected boolean isOwn(Data key)

getNearCache

public NearCache<Object,Object> getNearCache()

convertToData

protected <K> Iterable<Data> convertToData(Iterable<K> keys)

waitUntilLoaded

public void waitUntilLoaded()

size

public int size()

containsValueInternal

public boolean containsValueInternal(Data dataValue)

isEmpty

public boolean isEmpty()

putAllInternal

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

This method will group all puts per partition and send a PutAllPartitionAwareOperationFactory per member.

If there are e.g. five keys for a single member, there will only be a single remote invocation instead of having five remote invocations.

There is also an optional support for batching to send smaller packages. Takes care about null checks for keys and values.

flush

public void flush()

addMapInterceptorInternal

public String addMapInterceptorInternal(MapInterceptor interceptor)

removeMapInterceptorInternal

public void removeMapInterceptorInternal(String id)

addLocalEntryListenerInternal

public String addLocalEntryListenerInternal(Object listener)

addLocalEntryListenerInternal

public String addLocalEntryListenerInternal(Object listener,
                                            Predicate predicate,
                                            Data key,
                                            boolean includeValue)

addEntryListenerInternal

protected String addEntryListenerInternal(Object listener,
                                          Data key,
                                          boolean includeValue)

addEntryListenerInternal

protected String addEntryListenerInternal(Object listener,
                                          Predicate predicate,
                                          Data key,
                                          boolean includeValue)

removeEntryListenerInternal

protected boolean removeEntryListenerInternal(String id)

addPartitionLostListenerInternal

protected String addPartitionLostListenerInternal(MapPartitionLostListener listener)

removePartitionLostListenerInternal

protected boolean removePartitionLostListenerInternal(String id)

getEntryViewInternal

protected EntryView getEntryViewInternal(Data key)

toObject

protected <T> T toObject(Object object)

toData

protected Data toData(Object object,
                      PartitioningStrategy partitioningStrategy)

addIndex

public void addIndex(String attribute,
                     boolean ordered)

getLocalMapStats

public LocalMapStats getLocalMapStats()

getTimeInMillis

protected long getTimeInMillis(long time,
                               TimeUnit timeunit)

getMapQueryEngine

protected MapQueryEngine getMapQueryEngine()

isMapStoreEnabled

protected boolean isMapStoreEnabled()

getMapConfig

protected MapConfig getMapConfig()

getName

public final String getName()

Description copied from interface: DistributedObject

Returns the unique name for this DistributedObject. The returned value will never be null. The suggested way for getting name is retrieving it through DistributedObjectUtil.getName(DistributedObject) because this might be also a PrefixedDistributedObject.

Specified by:

getName in interface DistributedObject

Returns:

the unique name for this object.

getServiceName

public final String getServiceName()

Description copied from interface: DistributedObject

Returns the service name for this object.

Specified by:

getServiceName in interface DistributedObject

Specified by:

getServiceName in class AbstractDistributedObject<MapService>

Returns:

the service name for this object.

getPartitionStrategy

public PartitioningStrategy getPartitionStrategy()

setOperationProvider

public void setOperationProvider(MapOperationProvider operationProvider)

getOperationProvider

public MapOperationProvider getOperationProvider()

getTotalBackupCount

public int getTotalBackupCount()