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 String	name
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

Modifier and Type	Method and Description
void	checkWanReplicationQueues() Checks if WAN replication is enabled and if the WAN queues have reached their capacity.
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()
PartitioningStrategy	getPartitioningStrategy()
String	getQuorumName()
ConstructorFunction<Void,RecordFactory>	getRecordFactoryConstructor()
int	getTotalBackupCount()
MapMergePolicy	getWanMergePolicy()
WanReplicationPublisher	getWanReplicationPublisher()
boolean	hasInvalidationListener()
void	increaseInvalidationListenerCount()
void	initEvictor()
void	initWanReplication(NodeEngine nodeEngine)
boolean	isWanReplicationEnabled()
QueryableEntry	newQueryEntry(Data key, Object value)
void	onDestroy()
void	setEvictor(Evictor evictor)
void	setMapConfig(MapConfig mapConfig)
boolean	shouldCloneOnEntryProcessing()
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

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

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

Checks if WAN replication is enabled and if the WAN queues have reached their capacity.

Throws:

WANReplicationQueueFullException - if WAN replication is enabled and queue capacity has been reached

getTotalBackupCount

public int getTotalBackupCount()

getBackupCount

public int getBackupCount()

getAsyncBackupCount

public int getAsyncBackupCount()

getPartitioningStrategy

public PartitioningStrategy getPartitioningStrategy()

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

hasInvalidationListener

public boolean hasInvalidationListener()

increaseInvalidationListenerCount

public void increaseInvalidationListenerCount()

decreaseInvalidationListenerCount

public void decreaseInvalidationListenerCount()

getInterceptorRegistry

public InterceptorRegistry getInterceptorRegistry()

onDestroy

public void onDestroy()

shouldCloneOnEntryProcessing

public boolean shouldCloneOnEntryProcessing()