com.hazelcast.map.impl

Class MapContainer

java.lang.Object

com.hazelcast.map.impl.MapContainer

public class MapContainer
extends Object

Map container.

Field Summary

Fields

Modifier and Type	Field and Description
protected Evictor	evictor
protected Extractors	extractors
protected Indexes	indexes
protected Map<String,MapInterceptor>	interceptorMap
protected List<MapInterceptor>	interceptors
protected AtomicInteger	invalidationListenerCount Holds number of registered InvalidationListener from clients.
protected MapConfig	mapConfig
protected MapServiceContext	mapServiceContext
protected MapStoreContext	mapStoreContext
protected boolean	memberNearCacheInvalidationEnabled
protected String	name
protected SizeEstimator	nearCacheSizeEstimator
protected PartitioningStrategy	partitioningStrategy
protected QueryEntryFactory	queryEntryFactory
protected String	quorumName
protected ConstructorFunction<Void,RecordFactory>	recordFactoryConstructor
protected SerializationService	serializationService
protected IFunction<Object,Data>	toDataFunction
protected MapMergePolicy	wanMergePolicy
protected WanReplicationPublisher	wanReplicationPublisher

Constructor Summary

Constructors

Constructor and Description
MapContainer(String name, MapConfig mapConfig, MapServiceContext mapServiceContext) Operations which are done in this constructor should obey the rules defined in the method comment PostJoinAwareService.getPostJoinOperation() Otherwise undesired situations, like deadlocks, may appear.

Method Summary

Methods

Modifier and Type	Method and Description
void	addInterceptor(String id, MapInterceptor interceptor)
void	checkWanReplicationQueues()
void	decreaseInvalidationListenerCount()
int	getAsyncBackupCount()
int	getBackupCount()
Evictor	getEvictor()
Indexes	getIndexes()
Map<String,MapInterceptor>	getInterceptorMap()
List<MapInterceptor>	getInterceptors()
MapConfig	getMapConfig()
MapServiceContext	getMapServiceContext()
MapStoreContext	getMapStoreContext()
String	getName()
SizeEstimator	getNearCacheSizeEstimator()
PartitioningStrategy	getPartitioningStrategy()
String	getQuorumName()
ConstructorFunction<Void,RecordFactory>	getRecordFactoryConstructor()
int	getTotalBackupCount()
MapMergePolicy	getWanMergePolicy()
WanReplicationPublisher	getWanReplicationPublisher()
boolean	hasInvalidationListener()
void	increaseInvalidationListenerCount()
void	initWanReplication(NodeEngine nodeEngine)
boolean	isInvalidationEnabled()
boolean	isMemberNearCacheInvalidationEnabled()
boolean	isNearCacheEnabled()
boolean	isWanReplicationEnabled()
QueryableEntry	newQueryEntry(Data key, Object value)
void	removeInterceptor(String id)
void	setEvictor(Evictor evictor)
void	setMapConfig(MapConfig mapConfig)
IFunction<Object,Data>	toData()

Methods inherited from class java.lang.Object

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

Field Detail

name

protected final String name

quorumName

protected final String quorumName

mapServiceContext

protected final MapServiceContext mapServiceContext

interceptorMap

protected final Map<String,MapInterceptor> interceptorMap

indexes

protected final Indexes indexes

extractors

protected final Extractors extractors

nearCacheSizeEstimator

protected final SizeEstimator nearCacheSizeEstimator

partitioningStrategy

protected final PartitioningStrategy partitioningStrategy

mapStoreContext

protected final MapStoreContext mapStoreContext

serializationService

protected final SerializationService serializationService

queryEntryFactory

protected final QueryEntryFactory queryEntryFactory

interceptors

protected final List<MapInterceptor> interceptors

toDataFunction

protected final IFunction<Object,Data> toDataFunction

recordFactoryConstructor

protected final ConstructorFunction<Void,RecordFactory> recordFactoryConstructor

memberNearCacheInvalidationEnabled

protected final boolean memberNearCacheInvalidationEnabled

invalidationListenerCount

protected final AtomicInteger invalidationListenerCount

Holds number of registered InvalidationListener from clients.

wanReplicationPublisher

protected WanReplicationPublisher wanReplicationPublisher

wanMergePolicy

protected MapMergePolicy wanMergePolicy

evictor

protected Evictor evictor

mapConfig

protected volatile MapConfig mapConfig

Constructor Detail

MapContainer

public MapContainer(String name,
            MapConfig mapConfig,
            MapServiceContext mapServiceContext)

Operations which are done in this constructor should obey the rules defined in the method comment PostJoinAwareService.getPostJoinOperation() Otherwise undesired situations, like deadlocks, may appear.

Method Detail

initWanReplication

public void initWanReplication(NodeEngine nodeEngine)

getIndexes

public Indexes getIndexes()

getWanReplicationPublisher

public WanReplicationPublisher getWanReplicationPublisher()

getWanMergePolicy

public MapMergePolicy getWanMergePolicy()

addInterceptor

public void addInterceptor(String id,
                  MapInterceptor interceptor)

getInterceptors

public List<MapInterceptor> getInterceptors()

getInterceptorMap

public Map<String,MapInterceptor> getInterceptorMap()

removeInterceptor

public void removeInterceptor(String id)

isWanReplicationEnabled

public boolean isWanReplicationEnabled()

checkWanReplicationQueues

public void checkWanReplicationQueues()

isNearCacheEnabled

public boolean isNearCacheEnabled()

getTotalBackupCount

public int getTotalBackupCount()

getBackupCount

public int getBackupCount()

getAsyncBackupCount

public int getAsyncBackupCount()

getPartitioningStrategy

public PartitioningStrategy getPartitioningStrategy()

getNearCacheSizeEstimator

public SizeEstimator getNearCacheSizeEstimator()

getMapServiceContext

public MapServiceContext getMapServiceContext()

getMapStoreContext

public MapStoreContext getMapStoreContext()

getMapConfig

public MapConfig getMapConfig()

setMapConfig

public void setMapConfig(MapConfig mapConfig)

getName

public String getName()

getQuorumName

public String getQuorumName()

toData

public IFunction<Object,Data> toData()

getRecordFactoryConstructor

public ConstructorFunction<Void,RecordFactory> getRecordFactoryConstructor()

newQueryEntry

public QueryableEntry newQueryEntry(Data key,
                           Object value)

getEvictor

public Evictor getEvictor()

setEvictor

public void setEvictor(Evictor evictor)

isMemberNearCacheInvalidationEnabled

public boolean isMemberNearCacheInvalidationEnabled()

hasInvalidationListener

public boolean hasInvalidationListener()

increaseInvalidationListenerCount

public void increaseInvalidationListenerCount()

decreaseInvalidationListenerCount

public void decreaseInvalidationListenerCount()

isInvalidationEnabled

public boolean isInvalidationEnabled()