com.hazelcast.map

Interface MapServiceContext

All Superinterfaces:

MapServiceContextEventListenerSupport, MapServiceContextInterceptorSupport

All Known Implementing Classes:

DefaultMapServiceContext

public interface MapServiceContext
extends MapServiceContextInterceptorSupport, MapServiceContextEventListenerSupport

Context which is needed by a map service.

Shared instances, configurations of all maps can be reached over this context.

Also this context provides some support methods which are used in map operations and RecordStore implementations. For example all PartitionContainer and MapContainer instances can also be reached by using this interface.

It is also responsible for providing methods which are used by lower layers of Hazelcast and exposed on MapService.

See Also:

MapManagedService

Method Summary

Methods

Modifier and Type	Method and Description
void	clearPartitionData(int partitionId)
void	clearPartitions()
boolean	compare(String mapName, Object value1, Object value2)
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.
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()
List<Integer>	getOwnedPartitions()
PartitionContainer	getPartitionContainer(int partitionId)
RecordStore	getRecordStore(int partitionId, String mapName)
MapService	getService()
AtomicInteger	getWriteBehindQueueItemCounter()
void	initPartitionsContainers()
AtomicReference<List<Integer>>	ownedPartitions()
void	reset()
String	serviceName()
void	setService(MapService mapService)
Data	toData(Object object)
Data	toData(Object object, PartitioningStrategy partitionStrategy)
Object	toObject(Object data)

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

Method Detail

getMapContainer

MapContainer getMapContainer(String mapName)

getMapContainers

Map<String,MapContainer> getMapContainers()

getPartitionContainer

PartitionContainer getPartitionContainer(int partitionId)

initPartitionsContainers

void initPartitionsContainers()

clearPartitionData

void clearPartitionData(int partitionId)

serviceName

String serviceName()

getService

MapService getService()

clearPartitions

void clearPartitions()

destroyMapStores

void destroyMapStores()

flushMaps

void flushMaps()

destroyMap

void destroyMap(String mapName)

reset

void reset()

getNearCacheProvider

NearCacheProvider getNearCacheProvider()

getRecordStore

RecordStore getRecordStore(int partitionId,
                         String mapName)

getExistingRecordStore

RecordStore getExistingRecordStore(int partitionId,
                                 String mapName)

getOwnedPartitions

List<Integer> getOwnedPartitions()

ownedPartitions

AtomicReference<List<Integer>> ownedPartitions()

getMemberPartitions

List<Integer> getMemberPartitions()

getWriteBehindQueueItemCounter

AtomicInteger getWriteBehindQueueItemCounter()

getExpirationManager

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

setService

void setService(MapService mapService)

getNodeEngine

NodeEngine getNodeEngine()

getMergePolicyProvider

MergePolicyProvider getMergePolicyProvider()

getMapEventPublisher

MapEventPublisher getMapEventPublisher()

getMapContextQuerySupport

MapContextQuerySupport getMapContextQuerySupport()

getLocalMapStatsProvider

LocalMapStatsProvider getLocalMapStatsProvider()

getNow

long getNow()

convertTime

long convertTime(long seconds,
               TimeUnit unit)

toObject

Object toObject(Object data)

toData

Data toData(Object object,
          PartitioningStrategy partitionStrategy)

toData

Data toData(Object object)

compare

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

getExpirationTime

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.