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

Modifier and Type	Method and Description
String	addListenerAdapter(ListenerAdapter listenerAdaptor, EventFilter eventFilter, String mapName)
String	addListenerAdapter(String cacheName, ListenerAdapter listenerAdaptor)
String	addLocalListenerAdapter(ListenerAdapter listenerAdaptor, String mapName)
void	clearMapsHavingLesserBackupCountThan(int partitionId, int backupCount) Clears all map partitions which are expected to have lesser backups than given.
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()
MapEventJournal	getEventJournal()
RecordStore	getExistingRecordStore(int partitionId, String mapName)
ExpirationManager	getExpirationManager()
Extractors	getExtractors(String mapName)
IndexProvider	getIndexProvider(MapConfig mapConfig)
LocalMapStatsProvider	getLocalMapStatsProvider()
MapContainer	getMapContainer(String mapName)
Map<String,MapContainer>	getMapContainers()
MapEventPublisher	getMapEventPublisher()
MapNearCacheManager	getMapNearCacheManager()
MapOperationProvider	getMapOperationProvider(MapConfig mapConfig)
MapOperationProvider	getMapOperationProvider(String name)
MapQueryEngine	getMapQueryEngine(String name)
QueryRunner	getMapQueryRunner(String name)
MergePolicyProvider	getMergePolicyProvider()
NodeEngine	getNodeEngine()
Collection<Integer>	getOwnedPartitions()
PartitionContainer	getPartitionContainer(int partitionId)
PartitionContainer[]	getPartitionContainers()
PartitioningStrategy	getPartitioningStrategy(String mapName, PartitioningStrategyConfig config)
PartitionScanRunner	getPartitionScanRunner()
QueryCacheContext	getQueryCacheContext()
QueryOptimizer	getQueryOptimizer()
RecordComparator	getRecordComparator(InMemoryFormat inMemoryFormat)
RecordStore	getRecordStore(int partitionId, String mapName)
RecordStore	getRecordStore(int partitionId, String mapName, boolean skipLoadingOnCreate)
ResultProcessorRegistry	getResultProcessorRegistry()
MapService	getService()
AtomicInteger	getWriteBehindQueueItemCounter()
void	incrementOperationStats(long startTime, LocalMapStatsImpl localMapStats, String mapName, Operation operation)
void	initPartitionsContainers()
void	onClusterStateChange(ClusterState newState)
void	reloadOwnedPartitions() Reloads the cached collection of partitions owned by this node.
boolean	removeMapContainer(MapContainer mapContainer)
void	removePartitioningStrategyFromCache(String mapName)
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

getRecordComparator

RecordComparator getRecordComparator(InMemoryFormat inMemoryFormat)

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

clearMapsHavingLesserBackupCountThan

void clearMapsHavingLesserBackupCountThan(int partitionId,
                                          int backupCount)

Clears all map partitions which are expected to have lesser backups than given.

Parameters:

partitionId - partition ID

backupCount - backup count

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.

createRecordStore

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

getRecordStore

RecordStore getRecordStore(int partitionId,
                           String mapName)

getRecordStore

RecordStore getRecordStore(int partitionId,
                           String mapName,
                           boolean skipLoadingOnCreate)

getExistingRecordStore

RecordStore getExistingRecordStore(int partitionId,
                                   String mapName)

getOwnedPartitions

Collection<Integer> getOwnedPartitions()

reloadOwnedPartitions

void reloadOwnedPartitions()

Reloads the cached collection of partitions owned by this node.

getWriteBehindQueueItemCounter

AtomicInteger getWriteBehindQueueItemCounter()

getExpirationManager

ExpirationManager getExpirationManager()

setService

void setService(MapService mapService)

getNodeEngine

NodeEngine getNodeEngine()

getMergePolicyProvider

MergePolicyProvider getMergePolicyProvider()

getMapEventPublisher

MapEventPublisher getMapEventPublisher()

getEventJournal

MapEventJournal getEventJournal()

getMapQueryEngine

MapQueryEngine getMapQueryEngine(String name)

getMapQueryRunner

QueryRunner getMapQueryRunner(String name)

getQueryOptimizer

QueryOptimizer getQueryOptimizer()

getLocalMapStatsProvider

LocalMapStatsProvider getLocalMapStatsProvider()

getMapOperationProvider

MapOperationProvider getMapOperationProvider(String name)

getMapOperationProvider

MapOperationProvider getMapOperationProvider(MapConfig mapConfig)

getIndexProvider

IndexProvider getIndexProvider(MapConfig mapConfig)

getExtractors

Extractors getExtractors(String mapName)

incrementOperationStats

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

removeMapContainer

boolean removeMapContainer(MapContainer mapContainer)

getPartitioningStrategy

PartitioningStrategy getPartitioningStrategy(String mapName,
                                             PartitioningStrategyConfig config)

removePartitioningStrategyFromCache

void removePartitioningStrategyFromCache(String mapName)

getPartitionContainers

PartitionContainer[] getPartitionContainers()

onClusterStateChange

void onClusterStateChange(ClusterState newState)

getPartitionScanRunner

PartitionScanRunner getPartitionScanRunner()

getResultProcessorRegistry

ResultProcessorRegistry getResultProcessorRegistry()

getMapNearCacheManager

MapNearCacheManager getMapNearCacheManager()

getQueryCacheContext

QueryCacheContext getQueryCacheContext()

addListenerAdapter

String addListenerAdapter(String cacheName,
                          ListenerAdapter listenerAdaptor)

addListenerAdapter

String addListenerAdapter(ListenerAdapter listenerAdaptor,
                          EventFilter eventFilter,
                          String mapName)

addLocalListenerAdapter

String addLocalListenerAdapter(ListenerAdapter listenerAdaptor,
                               String mapName)