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	addLocalListenerAdapter(ListenerAdapter listenerAdaptor, String mapName)
RecordStore	createRecordStore(MapContainer mapContainer, int partitionId, MapKeyLoader keyLoader)
Collection<RecordStoreMutationObserver<Record>>	createRecordStoreMutationObservers(String mapName, int partitionId) Returns the collection of the RecordStoreMutationObservers for the given map's partition that need to be added in record store construction time in order to ensure no RecordStore mutations are missed.
void	destroyMap(String mapName)
void	destroyMapStores()
void	flushMaps()
MapClearExpiredRecordsTask	getClearExpiredRecordsTask()
MapEventJournal	getEventJournal()
RecordStore	getExistingRecordStore(int partitionId, String mapName)
ExpirationManager	getExpirationManager()
Extractors	getExtractors(String mapName)
IndexCopyBehavior	getIndexCopyBehavior()
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)
QueryRunner	getMapQueryRunner(String name)
Object	getMergePolicy(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()
QueryEngine	getQueryEngine(String name)
QueryOptimizer	getQueryOptimizer()
RecordStore	getRecordStore(int partitionId, String mapName)
RecordStore	getRecordStore(int partitionId, String mapName, boolean skipLoadingOnCreate)
ResultProcessorRegistry	getResultProcessorRegistry()
MapService	getService()
ValueComparator	getValueComparatorOf(InMemoryFormat inMemoryFormat)
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	removeRecordStoresFromPartitionMatchingWith(Predicate<RecordStore> predicate, int partitionId, boolean onShutdown, boolean onRecordStoreDestroy) Removes all record stores inside the supplied partition ID matching with the supplied predicate.
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()

removeRecordStoresFromPartitionMatchingWith

void removeRecordStoresFromPartitionMatchingWith(Predicate<RecordStore> predicate,
                                                 int partitionId,
                                                 boolean onShutdown,
                                                 boolean onRecordStoreDestroy)

Removes all record stores inside the supplied partition ID matching with the supplied predicate.

Parameters:

predicate - to find partitions to be removed

partitionId - partition ID

onShutdown - true if this method is called during map service shutdown, otherwise set false

onRecordStoreDestroy - true if this method is called during to destroy record store, otherwise set false

See Also:

MapManagedService.reset(), MapManagedService.shutdown(boolean)

getService

MapService getService()

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

getMergePolicy

Object getMergePolicy(String name)

getMapEventPublisher

MapEventPublisher getMapEventPublisher()

getEventJournal

MapEventJournal getEventJournal()

getQueryEngine

QueryEngine getQueryEngine(String name)

getMapQueryRunner

QueryRunner getMapQueryRunner(String name)

getQueryOptimizer

QueryOptimizer getQueryOptimizer()

getLocalMapStatsProvider

LocalMapStatsProvider getLocalMapStatsProvider()

getClearExpiredRecordsTask

MapClearExpiredRecordsTask getClearExpiredRecordsTask()

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(ListenerAdapter listenerAdaptor,
                          EventFilter eventFilter,
                          String mapName)

addLocalListenerAdapter

String addLocalListenerAdapter(ListenerAdapter listenerAdaptor,
                               String mapName)

getIndexCopyBehavior

IndexCopyBehavior getIndexCopyBehavior()

createRecordStoreMutationObservers

Collection<RecordStoreMutationObserver<Record>> createRecordStoreMutationObservers(String mapName,
                                                                                   int partitionId)

Returns the collection of the RecordStoreMutationObservers for the given map's partition that need to be added in record store construction time in order to ensure no RecordStore mutations are missed.

Parameters:

mapName - The name of the map

partitionId - The partition

Returns:

The collection of the observers

getValueComparatorOf

ValueComparator getValueComparatorOf(InMemoryFormat inMemoryFormat)