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>, 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 boolean	cacheLocalEntries
protected LocalMapStatsImpl	localMapStats
protected LockProxySupport	lockSupport
protected MapContainer	mapContainer
protected MapServiceContext	mapServiceContext
protected String	name
protected NearCache	nearCache
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_VALUE_IS_NOT_ALLOWED
protected MapOperationProvider	operationProvider
protected OperationService	operationService
protected InternalPartitionService	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)

Method Summary

Methods

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 Future	createPutAllOperationFuture(String name, MapEntries mapEntries, int partitionId)
protected void	deleteInternal(Data key)
protected void	evictAllInternal()
protected boolean	evictInternal(Data key)
void	executeOnEntriesInternal(EntryProcessor entryProcessor, Predicate predicate, List<Data> resultingKeyValuePairs) IMap.executeOnEntries(EntryProcessor, Predicate)
Data	executeOnKeyInternal(Data key, EntryProcessor entryProcessor)
ICompletableFuture	executeOnKeyInternal(Data key, EntryProcessor entryProcessor, ExecutionCallback callback)
Map	executeOnKeysInternal(Set<Data> keys, EntryProcessor entryProcessor)
void	flush()
protected void	getAllObjectInternal(List<Data> keys, List resultingKeyValuePairs)
protected ICompletableFuture<Data>	getAsyncInternal(Data key)
protected Object	getCachedValue(Data key)
protected void	getCachedValue(List<Data> keys, List<Object> resultingKeyValuePairs)
protected EntryView	getEntryViewInternal(Data key)
protected Object	getInternal(Data key)
LocalMapStats	getLocalMapStats()
protected MapConfig	getMapConfig()
protected MapQueryEngine	getMapQueryEngine()
protected MapStore	getMapStore()
String	getName() Returns the unique name for this DistributedObject.
NearCache	getNearCache()
PartitioningStrategy	getPartitionStrategy()
String	getServiceName() Returns the service name for this object.
protected long	getTimeInMillis(long time, TimeUnit timeunit)
protected void	init()
void	initialize()
protected void	invalidateCache(Collection<Data> keys)
protected void	invalidateCache(Data key)
protected void	invalidateCache(Iterable<Data> keys)
protected boolean	isCachedNull(Object value)
boolean	isEmpty()
protected boolean	isOwn(Data key)
void	loadAllInternal(boolean replaceExistingValues)
protected void	loadInternal(Iterable keys, boolean replaceExistingValues) Maps keys to corresponding partitions and sends operations to them.
protected void	putAllInternal(Map<? extends Object,? extends Object> m) This Operation will first group all puts per partition and then send a PutAllOperation per partition.
protected ICompletableFuture<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 ICompletableFuture<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 ICompletableFuture<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 obj)
protected Data	toData(Object o, PartitioningStrategy partitioningStrategy)
protected <T> T	toObject(Object obj)
protected boolean	tryPutInternal(Data key, Data value, long timeout, TimeUnit timeunit)
protected boolean	tryRemoveInternal(Data key, long timeout, TimeUnit timeunit)
void	waitUntilFlushed()
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, clear, clearMapOnly, containsKey, containsValue, delete, entrySet, entrySet, evict, evictAll, executeOnEntries, executeOnEntries, executeOnKey, executeOnKeys, forceUnlock, get, getAll, getAsync, getEntryView, invoke, isLocked, keySet, keySet, loadAll, loadAll, localKeySet, localKeySet, lock, lock, put, put, putAll, putAsync, putAsync, putIfAbsent, putIfAbsent, putTransient, remove, remove, 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, getNameAsPartitionAwareData, getNodeEngine, getOperationService, getPartitionId, getPartitionKey, getService, hashCode, invalidate, postDestroy, throwNotActiveException

Methods inherited from class java.lang.Object

clone, 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.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

nearCache

protected NearCache nearCache

cacheLocalEntries

protected boolean cacheLocalEntries

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

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 InternalPartitionService partitionService

thisAddress

protected final Address thisAddress

mapContainer

protected final MapContainer mapContainer

operationService

protected final OperationService operationService

serializationService

protected final SerializationService serializationService

statisticsEnabled

protected final boolean statisticsEnabled

operationProvider

protected MapOperationProvider operationProvider

Constructor Detail

NearCachedMapProxyImpl

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

Method Detail

initialize

public void initialize()

Specified by:

initialize in interface InitializingObject

init

protected void init()

getInternal

protected Object getInternal(Data key)

getAsyncInternal

protected ICompletableFuture<Data> getAsyncInternal(Data key)

isCachedNull

protected boolean isCachedNull(Object value)

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 ICompletableFuture<Data> putAsyncInternal(Data key,
                                        Data value,
                                        long ttl,
                                        TimeUnit timeunit)

setAsyncInternal

protected ICompletableFuture<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)

evictAllInternal

protected void evictAllInternal()

loadAllInternal

public void loadAllInternal(boolean replaceExistingValues)

loadInternal

protected void loadInternal(Iterable keys,
                boolean replaceExistingValues)

Maps keys to corresponding partitions and sends operations to them.

removeInternal

protected Data removeInternal(Data key)

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 ICompletableFuture<Data> removeAsyncInternal(Data key)

containsKeyInternal

protected boolean containsKeyInternal(Data keyData)

getAllObjectInternal

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

createPutAllOperationFuture

protected Future createPutAllOperationFuture(String name,
                                 MapEntries mapEntries,
                                 int partitionId)

executeOnKeyInternal

public Data executeOnKeyInternal(Data key,
                        EntryProcessor entryProcessor)

executeOnKeysInternal

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

executeOnKeyInternal

public ICompletableFuture executeOnKeyInternal(Data key,
                                      EntryProcessor entryProcessor,
                                      ExecutionCallback callback)

executeOnEntriesInternal

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

IMap.executeOnEntries(EntryProcessor, Predicate)

getCachedValue

protected Object getCachedValue(Data key)

getCachedValue

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

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

convertToData

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

waitUntilLoaded

public void waitUntilLoaded()

waitUntilFlushed

public void waitUntilFlushed()

size

public int size()

containsValueInternal

public boolean containsValueInternal(Data dataValue)

isEmpty

public boolean isEmpty()

putAllInternal

protected void putAllInternal(Map<? extends Object,? extends Object> m)

This Operation will first group all puts per partition and then send a PutAllOperation per partition. So if there are e.g. 5 keys for a single partition, then instead of having 5 remote invocations, there will be only 1 remote invocation.

If there are multiple puts for different partitions on the same member, they are executed as different remote operations. Probably this can be optimized in the future by making use of an PartitionIterating operation.

Parameters:

m -

flush

public void flush()

clearInternal

public void clearInternal()

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

toData

protected Data toData(Object obj)

toData

protected Data toData(Object o,
          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()

getMapStore

protected MapStore getMapStore()

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.

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)