com.hazelcast.map.impl

Class MapContainer

java.lang.Object

com.hazelcast.map.impl.MapContainer

public class MapContainer
extends Object

Map container for a map with a specific name. Contains config and supporting structures for all of the maps' functionalities.

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	addEventPublishingEnabled
protected EventJournalConfig	eventJournalConfig
protected Evictor	evictor
protected Extractors	extractors
protected Indexes	globalIndexes
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 ObjectNamespace	objectNamespace
protected Set<IndexInfo>	partitionIndexesToAdd Definitions of indexes that need to be added on partition threads
protected PartitioningStrategy	partitioningStrategy
protected QueryEntryFactory	queryEntryFactory
protected String	quorumName
protected ConstructorFunction<Void,RecordFactory>	recordFactoryConstructor
protected SerializationService	serializationService
protected IFunction<Object,Data>	toDataFunction
protected Object	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	addPartitionIndexToAdd(IndexInfo indexInfo)
void	checkWanReplicationQueues() Checks if WAN replication is enabled and if the WAN queues have reached their capacity.
void	clearPartitionIndexesToAdd()
Indexes	createIndexes(boolean global)
void	decreaseInvalidationListenerCount()
int	getAsyncBackupCount()
int	getBackupCount()
EventJournalConfig	getEventJournalConfig()
Evictor	getEvictor()
Extractors	getExtractors()
Map<String,Boolean>	getIndexDefinitions()
Indexes	getIndexes()
Indexes	getIndexes(int partitionId)
InterceptorRegistry	getInterceptorRegistry()
MapConfig	getMapConfig()
MapServiceContext	getMapServiceContext()
MapStoreContext	getMapStoreContext()
protected static MemoryInfoAccessor	getMemoryInfoAccessor()
String	getName()
ObjectNamespace	getObjectNamespace()
Set<IndexInfo>	getPartitionIndexesToAdd()
PartitioningStrategy	getPartitioningStrategy()
String	getQuorumName()
ConstructorFunction<Void,RecordFactory>	getRecordFactoryConstructor()
int	getTotalBackupCount()
Object	getWanMergePolicy()
WanReplicationPublisher	getWanReplicationPublisher()
boolean	hasInvalidationListener()
void	increaseInvalidationListenerCount()
void	initEvictor()
void	initWanReplication(NodeEngine nodeEngine)
boolean	isAddEventPublishingEnabled()
boolean	isGlobalIndexEnabled()
boolean	isPersistWanReplicatedData()
boolean	isWanReplicationEnabled()
boolean	isWanRepublishingEnabled()
QueryableEntry	newQueryEntry(Data key, Object value)
void	onDestroy()
void	setEvictor(Evictor evictor)
void	setMapConfig(MapConfig mapConfig)
boolean	shouldCloneOnEntryProcessing(int partitionId)
protected boolean	shouldUseGlobalIndex(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

addEventPublishingEnabled

protected final boolean addEventPublishingEnabled

name

protected final String name

quorumName

protected final String quorumName

globalIndexes

protected final Indexes globalIndexes

extractors

protected final Extractors extractors

mapStoreContext

protected final MapStoreContext mapStoreContext

objectNamespace

protected final ObjectNamespace objectNamespace

mapServiceContext

protected final MapServiceContext mapServiceContext

queryEntryFactory

protected final QueryEntryFactory queryEntryFactory

eventJournalConfig

protected final EventJournalConfig eventJournalConfig

partitioningStrategy

protected final PartitioningStrategy partitioningStrategy

serializationService

protected final SerializationService serializationService

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.

partitionIndexesToAdd

protected final Set<IndexInfo> partitionIndexesToAdd

Definitions of indexes that need to be added on partition threads

See Also:

MapIndexSynchronizer, SynchronizeIndexesForPartitionTask, PostJoinMapOperation, MapReplicationStateHolder

wanMergePolicy

protected Object wanMergePolicy

wanReplicationPublisher

protected WanReplicationPublisher wanReplicationPublisher

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

createIndexes

public Indexes createIndexes(boolean global)

Parameters:

global - set true to create global indexes, otherwise set false to have partitioned indexes

Returns:

a new Indexes object

isAddEventPublishingEnabled

public boolean isAddEventPublishingEnabled()

initEvictor

public void initEvictor()

shouldUseGlobalIndex

protected boolean shouldUseGlobalIndex(MapConfig mapConfig)

getMemoryInfoAccessor

protected static MemoryInfoAccessor getMemoryInfoAccessor()

initWanReplication

public void initWanReplication(NodeEngine nodeEngine)

getIndexes

public Indexes getIndexes()

Returns:

the global index, if the global index is in use (on-heap) or null.

getIndexes

public Indexes getIndexes(int partitionId)

Parameters:

partitionId - partitionId

isGlobalIndexEnabled

public boolean isGlobalIndexEnabled()

getWanReplicationPublisher

public WanReplicationPublisher getWanReplicationPublisher()

getWanMergePolicy

public Object getWanMergePolicy()

isWanReplicationEnabled

public boolean isWanReplicationEnabled()

isWanRepublishingEnabled

public boolean isWanRepublishingEnabled()

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)

getEventJournalConfig

public EventJournalConfig getEventJournalConfig()

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

getObjectNamespace

public ObjectNamespace getObjectNamespace()

getIndexDefinitions

public Map<String,Boolean> getIndexDefinitions()

addPartitionIndexToAdd

public void addPartitionIndexToAdd(IndexInfo indexInfo)

getPartitionIndexesToAdd

public Set<IndexInfo> getPartitionIndexesToAdd()

clearPartitionIndexesToAdd

public void clearPartitionIndexesToAdd()

isPersistWanReplicatedData

public boolean isPersistWanReplicatedData()