com.hazelcast.map

Class DefaultMapServiceContext

java.lang.Object

com.hazelcast.map.DefaultMapServiceContext

All Implemented Interfaces:

MapServiceContext, MapServiceContextEventListenerSupport, MapServiceContextInterceptorSupport

public class DefaultMapServiceContext
extends Object
implements MapServiceContext

Default implementation of map service context.

Field Summary

Fields

Modifier and Type	Field and Description
protected NodeEngine	nodeEngine

Constructor Summary

Constructors

Constructor and Description
DefaultMapServiceContext(NodeEngine nodeEngine)

Method Summary

Methods

Modifier and Type	Method and Description
String	addEventListener(EntryListener entryListener, EventFilter eventFilter, String mapName)
String	addInterceptor(String mapName, MapInterceptor interceptor)
String	addLocalEventListener(EntryListener entryListener, EventFilter eventFilter, String mapName)
String	addLocalEventListener(EntryListener entryListener, String mapName)
void	clearPartitionData(int partitionId)
void	clearPartitions()
boolean	compare(String mapName, Object value1, Object value2)
boolean	compare(String mapName, Object value1, Object value2)
long	convertTime(long seconds, TimeUnit unit)
long	convertTime(long seconds, TimeUnit unit)
void	destroyMap(String mapName)
void	destroyMapStores()
void	flushMaps()
RecordStore	getExistingRecordStore(int partitionId, String mapName)
com.hazelcast.map.eviction.ExpirationManager	getExpirationManager()
long	getExpirationTime(long ttl, long now) Returns expiration time.
long	getExpirationTime(long ttl, long now) Returns expiration time.
LocalMapStatsProvider	getLocalMapStatsProvider()
MapContainer	getMapContainer(String mapName)
Map<String,MapContainer>	getMapContainers()
MapContextQuerySupport	getMapContextQuerySupport()
MapEventPublisher	getMapEventPublisher()
List<Integer>	getMemberPartitions()
MergePolicyProvider	getMergePolicyProvider()
NearCacheProvider	getNearCacheProvider()
NodeEngine	getNodeEngine()
long	getNow()
long	getNow()
List<Integer>	getOwnedPartitions()
PartitionContainer	getPartitionContainer(int partitionId)
RecordStore	getRecordStore(int partitionId, String mapName)
MapService	getService()
AtomicInteger	getWriteBehindQueueItemCounter()
boolean	hasRegisteredListener(String name)
void	initPartitionsContainers()
void	interceptAfterGet(String mapName, Object value)
void	interceptAfterPut(String mapName, Object newValue)
void	interceptAfterRemove(String mapName, Object value)
Object	interceptGet(String mapName, Object value)
Object	interceptPut(String mapName, Object oldValue, Object newValue)
Object	interceptRemove(String mapName, Object value)
AtomicReference<List<Integer>>	ownedPartitions()
boolean	removeEventListener(String mapName, String registrationId)
void	removeInterceptor(String mapName, String id)
void	reset()
String	serviceName()
void	setMapServiceContext(MapServiceContext mapServiceContext)
void	setService(MapService mapService)
Data	toData(Object object)
Data	toData(Object object)
Data	toData(Object object, PartitioningStrategy partitionStrategy)
Data	toData(Object object, PartitioningStrategy partitionStrategy)
Object	toObject(Object data)
Object	toObject(Object data)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hazelcast.map.MapServiceContextInterceptorSupport

addInterceptor, interceptAfterGet, interceptAfterPut, interceptAfterRemove, interceptGet, interceptPut, interceptRemove, removeInterceptor

Methods inherited from interface com.hazelcast.map.MapServiceContextEventListenerSupport

addEventListener, addLocalEventListener, addLocalEventListener, hasRegisteredListener, removeEventListener

Field Detail

nodeEngine

protected NodeEngine nodeEngine

Constructor Detail

DefaultMapServiceContext

public DefaultMapServiceContext(NodeEngine nodeEngine)

Method Detail

getMapContainer

public MapContainer getMapContainer(String mapName)

Specified by:

getMapContainer in interface MapServiceContext

getMapContainers

public Map<String,MapContainer> getMapContainers()

Specified by:

getMapContainers in interface MapServiceContext

getPartitionContainer

public PartitionContainer getPartitionContainer(int partitionId)

Specified by:

getPartitionContainer in interface MapServiceContext

initPartitionsContainers

public void initPartitionsContainers()

Specified by:

initPartitionsContainers in interface MapServiceContext

clearPartitionData

public void clearPartitionData(int partitionId)

Specified by:

clearPartitionData in interface MapServiceContext

serviceName

public String serviceName()

Specified by:

serviceName in interface MapServiceContext

getService

public MapService getService()

Specified by:

getService in interface MapServiceContext

clearPartitions

public void clearPartitions()

Specified by:

clearPartitions in interface MapServiceContext

destroyMapStores

public void destroyMapStores()

Specified by:

destroyMapStores in interface MapServiceContext

flushMaps

public void flushMaps()

Specified by:

flushMaps in interface MapServiceContext

destroyMap

public void destroyMap(String mapName)

Specified by:

destroyMap in interface MapServiceContext

reset

public void reset()

Specified by:

reset in interface MapServiceContext

getNearCacheProvider

public NearCacheProvider getNearCacheProvider()

Specified by:

getNearCacheProvider in interface MapServiceContext

getRecordStore

public RecordStore getRecordStore(int partitionId,
                         String mapName)

Specified by:

getRecordStore in interface MapServiceContext

getExistingRecordStore

public RecordStore getExistingRecordStore(int partitionId,
                                 String mapName)

Specified by:

getExistingRecordStore in interface MapServiceContext

getOwnedPartitions

public List<Integer> getOwnedPartitions()

Specified by:

getOwnedPartitions in interface MapServiceContext

ownedPartitions

public AtomicReference<List<Integer>> ownedPartitions()

Specified by:

ownedPartitions in interface MapServiceContext

getMemberPartitions

public List<Integer> getMemberPartitions()

Specified by:

getMemberPartitions in interface MapServiceContext

getWriteBehindQueueItemCounter

public AtomicInteger getWriteBehindQueueItemCounter()

Specified by:

getWriteBehindQueueItemCounter in interface MapServiceContext

getExpirationManager

public com.hazelcast.map.eviction.ExpirationManager getExpirationManager()

Specified by:

getExpirationManager in interface MapServiceContext

setService

public void setService(MapService mapService)

Specified by:

setService in interface MapServiceContext

getNodeEngine

public NodeEngine getNodeEngine()

Specified by:

getNodeEngine in interface MapServiceContext

getMergePolicyProvider

public MergePolicyProvider getMergePolicyProvider()

Specified by:

getMergePolicyProvider in interface MapServiceContext

getMapEventPublisher

public MapEventPublisher getMapEventPublisher()

Specified by:

getMapEventPublisher in interface MapServiceContext

getMapContextQuerySupport

public MapContextQuerySupport getMapContextQuerySupport()

Specified by:

getMapContextQuerySupport in interface MapServiceContext

getLocalMapStatsProvider

public LocalMapStatsProvider getLocalMapStatsProvider()

Specified by:

getLocalMapStatsProvider in interface MapServiceContext

getNow

public long getNow()

convertTime

public long convertTime(long seconds,
               TimeUnit unit)

toObject

public Object toObject(Object data)

toData

public Data toData(Object object,
          PartitioningStrategy partitionStrategy)

toData

public Data toData(Object object)

compare

public boolean compare(String mapName,
              Object value1,
              Object value2)

getExpirationTime

public long getExpirationTime(long ttl,
                     long now)

Returns expiration time.

- Detects potential long overflow and returns Long.MAX_VALUE in an overflow situation.

- If ttl is zero to state an eternal live, it returns Long.MAX_VALUE

Parameters:

ttl - time to live

now - now

Returns:

expiration time

Throws:

IllegalArgumentException - when ttl < 0 or now < 0.

setMapServiceContext

public void setMapServiceContext(MapServiceContext mapServiceContext)

getNow

public long getNow()

convertTime

public long convertTime(long seconds,
               TimeUnit unit)

getExpirationTime

public long getExpirationTime(long ttl,
                     long now)

Returns expiration time.

- Detects potential long overflow and returns Long.MAX_VALUE in an overflow situation.

- If ttl is zero to state an eternal live, it returns Long.MAX_VALUE

Parameters:

ttl - time to live

now - now

Returns:

expiration time

toObject

public Object toObject(Object data)

toData

public Data toData(Object object,
          PartitioningStrategy partitionStrategy)

toData

public Data toData(Object object)

compare

public boolean compare(String mapName,
              Object value1,
              Object value2)

interceptAfterGet

public void interceptAfterGet(String mapName,
                     Object value)

Specified by:

interceptAfterGet in interface MapServiceContextInterceptorSupport

interceptPut

public Object interceptPut(String mapName,
                  Object oldValue,
                  Object newValue)

Specified by:

interceptPut in interface MapServiceContextInterceptorSupport

interceptAfterPut

public void interceptAfterPut(String mapName,
                     Object newValue)

Specified by:

interceptAfterPut in interface MapServiceContextInterceptorSupport

interceptRemove

public Object interceptRemove(String mapName,
                     Object value)

Specified by:

interceptRemove in interface MapServiceContextInterceptorSupport

interceptAfterRemove

public void interceptAfterRemove(String mapName,
                        Object value)

Specified by:

interceptAfterRemove in interface MapServiceContextInterceptorSupport

addInterceptor

public String addInterceptor(String mapName,
                    MapInterceptor interceptor)

Specified by:

addInterceptor in interface MapServiceContextInterceptorSupport

removeInterceptor

public void removeInterceptor(String mapName,
                     String id)

Specified by:

removeInterceptor in interface MapServiceContextInterceptorSupport

interceptGet

public Object interceptGet(String mapName,
                  Object value)

Specified by:

interceptGet in interface MapServiceContextInterceptorSupport

addLocalEventListener

public String addLocalEventListener(EntryListener entryListener,
                           String mapName)

Specified by:

addLocalEventListener in interface MapServiceContextEventListenerSupport

addLocalEventListener

public String addLocalEventListener(EntryListener entryListener,
                           EventFilter eventFilter,
                           String mapName)

Specified by:

addLocalEventListener in interface MapServiceContextEventListenerSupport

addEventListener

public String addEventListener(EntryListener entryListener,
                      EventFilter eventFilter,
                      String mapName)

Specified by:

addEventListener in interface MapServiceContextEventListenerSupport

removeEventListener

public boolean removeEventListener(String mapName,
                          String registrationId)

Specified by:

removeEventListener in interface MapServiceContextEventListenerSupport

hasRegisteredListener

public boolean hasRegisteredListener(String name)

Specified by:

hasRegisteredListener in interface MapServiceContextEventListenerSupport