com.hazelcast.map.impl

Interface MapServiceContext

All Superinterfaces:

MapServiceContextEventListenerSupport, MapServiceContextInterceptorSupport

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 onShutdown) Clears all partition based data allocated by MapService.
RecordStore	createRecordStore(MapContainer mapContainer, int partitionId, MapKeyLoader keyLoader)
void	destroyMap(String mapName)
void	destroyMapStores()
void	flushMaps()
RecordStore	getExistingRecordStore(int partitionId, String mapName)
ExpirationManager	getExpirationManager()
Extractors	getExtractors(String mapName)
LocalMapStatsProvider	getLocalMapStatsProvider()
MapContainer	getMapContainer(String mapName)
Map<String,MapContainer>	getMapContainers()
MapEventPublisher	getMapEventPublisher()
MapOperationProvider	getMapOperationProvider(String name)
MapQueryEngine	getMapQueryEngine(String name)
MergePolicyProvider	getMergePolicyProvider()
NearCacheProvider	getNearCacheProvider()
NodeEngine	getNodeEngine()
Collection<Integer>	getOwnedPartitions()
PartitionContainer	getPartitionContainer(int partitionId)
RecordStore	getRecordStore(int partitionId, String mapName)
MapService	getService()
AtomicInteger	getWriteBehindQueueItemCounter()
void	incrementOperationStats(long startTime, LocalMapStatsImpl localMapStats, String mapName, Operation operation)
void	initPartitionsContainers()
void	reloadOwnedPartitions()
void	reset()
void	setService(MapService mapService)
void	shutdown() Releases internal resources solely managed by Hazelcast.
Data	toData(Object object)
Data	toData(Object object, PartitioningStrategy partitionStrategy)
Object	toObject(Object data)

Methods inherited from interface com.hazelcast.map.impl.MapServiceContextInterceptorSupport

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

Methods inherited from interface com.hazelcast.map.impl.MapServiceContextEventListenerSupport

addEventListener, addLocalEventListener, addLocalEventListener, addLocalPartitionLostListener, addPartitionLostListener, removeEventListener, removePartitionLostListener

Method Detail

toObject

Object toObject(Object data)

toData

Data toData(Object object,
          PartitioningStrategy partitionStrategy)

toData

Data toData(Object object)

getMapContainer

MapContainer getMapContainer(String mapName)

getMapContainers

Map<String,MapContainer> getMapContainers()

getPartitionContainer

PartitionContainer getPartitionContainer(int partitionId)

initPartitionsContainers

void initPartitionsContainers()

clearPartitionData

void clearPartitionData(int partitionId)

getService

MapService getService()

clearPartitions

void clearPartitions(boolean onShutdown)

Clears all partition based data allocated by MapService.

Parameters:

onShutdown - true if clearPartitions is called during MapService shutdown, false otherwise.

destroyMapStores

void destroyMapStores()

flushMaps

void flushMaps()

destroyMap

void destroyMap(String mapName)

reset

void reset()

shutdown

void shutdown()

Releases internal resources solely managed by Hazelcast. This method is called when MapService is shutting down.

getNearCacheProvider

NearCacheProvider getNearCacheProvider()

createRecordStore

RecordStore createRecordStore(MapContainer mapContainer,
                            int partitionId,
                            MapKeyLoader keyLoader)

getRecordStore

RecordStore getRecordStore(int partitionId,
                         String mapName)

getExistingRecordStore

RecordStore getExistingRecordStore(int partitionId,
                                 String mapName)

getOwnedPartitions

Collection<Integer> getOwnedPartitions()

reloadOwnedPartitions

void reloadOwnedPartitions()

getWriteBehindQueueItemCounter

AtomicInteger getWriteBehindQueueItemCounter()

getExpirationManager

ExpirationManager getExpirationManager()

setService

void setService(MapService mapService)

getNodeEngine

NodeEngine getNodeEngine()

getMergePolicyProvider

MergePolicyProvider getMergePolicyProvider()

getMapEventPublisher

MapEventPublisher getMapEventPublisher()

getMapQueryEngine

MapQueryEngine getMapQueryEngine(String name)

getLocalMapStatsProvider

LocalMapStatsProvider getLocalMapStatsProvider()

getMapOperationProvider

MapOperationProvider getMapOperationProvider(String name)

getExtractors

Extractors getExtractors(String mapName)

incrementOperationStats

void incrementOperationStats(long startTime,
                           LocalMapStatsImpl localMapStats,
                           String mapName,
                           Operation operation)