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 InterceptorRegistry	interceptorRegistry
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, Config config, 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	checkWanReplicationQueues()
void	decreaseInvalidationListenerCount()
int	getAsyncBackupCount()
int	getBackupCount()
Evictor	getEvictor()
Extractors	getExtractors()
Indexes	getIndexes()
InterceptorRegistry	getInterceptorRegistry()
MapConfig	getMapConfig()
MapServiceContext	getMapServiceContext()
MapStoreContext	getMapStoreContext()
protected static MemoryInfoAccessor	getMemoryInfoAccessor()
String	getName()
SizeEstimator	getNearCacheSizeEstimator()
PartitioningStrategy	getPartitioningStrategy()
String	getQuorumName()
ConstructorFunction<Void,RecordFactory>	getRecordFactoryConstructor()
int	getTotalBackupCount()
MapMergePolicy	getWanMergePolicy()
WanReplicationPublisher	getWanReplicationPublisher()
boolean	hasInvalidationListener()
boolean	hasMemberNearCache()
void	increaseInvalidationListenerCount()
void	initEvictor()
void	initWanReplication(NodeEngine nodeEngine)
boolean	isInvalidationEnabled()
boolean	isMemberNearCacheInvalidationEnabled()
boolean	isWanReplicationEnabled()
QueryableEntry	newQueryEntry(Data key, Object value)
void	onDestroy()
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

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

interceptorRegistry

protected final InterceptorRegistry interceptorRegistry

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 volatile Evictor evictor

mapConfig

protected volatile MapConfig mapConfig

Constructor Detail

MapContainer

public MapContainer(String name,
            Config config,
            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

initEvictor

public void initEvictor()

getMemoryInfoAccessor

protected static MemoryInfoAccessor getMemoryInfoAccessor()

initWanReplication

public void initWanReplication(NodeEngine nodeEngine)

getIndexes

public Indexes getIndexes()

getWanReplicationPublisher

public WanReplicationPublisher getWanReplicationPublisher()

getWanMergePolicy

public MapMergePolicy getWanMergePolicy()

isWanReplicationEnabled

public boolean isWanReplicationEnabled()

checkWanReplicationQueues

public void checkWanReplicationQueues()

hasMemberNearCache

public boolean hasMemberNearCache()

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)

getExtractors

public Extractors getExtractors()

isMemberNearCacheInvalidationEnabled

public boolean isMemberNearCacheInvalidationEnabled()

hasInvalidationListener

public boolean hasInvalidationListener()

increaseInvalidationListenerCount

public void increaseInvalidationListenerCount()

decreaseInvalidationListenerCount

public void decreaseInvalidationListenerCount()

isInvalidationEnabled

public boolean isInvalidationEnabled()

getInterceptorRegistry

public InterceptorRegistry getInterceptorRegistry()

onDestroy

public void onDestroy()