public class MapContainer extends Object
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 PartitioningStrategy |
partitioningStrategy |
protected QueryEntryFactory |
queryEntryFactory |
protected String |
quorumName |
protected ConstructorFunction<Void,RecordFactory> |
recordFactoryConstructor |
protected InternalSerializationService |
serializationService |
protected IFunction<Object,Data> |
toDataFunction |
protected Object |
wanMergePolicy |
protected WanReplicationPublisher |
wanReplicationPublisher |
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. |
protected final boolean addEventPublishingEnabled
protected final String name
protected final String quorumName
protected final Indexes globalIndexes
protected final Extractors extractors
protected final MapStoreContext mapStoreContext
protected final ObjectNamespace objectNamespace
protected final MapServiceContext mapServiceContext
protected final QueryEntryFactory queryEntryFactory
protected final EventJournalConfig eventJournalConfig
protected final PartitioningStrategy partitioningStrategy
protected final InternalSerializationService serializationService
protected final InterceptorRegistry interceptorRegistry
protected final ConstructorFunction<Void,RecordFactory> recordFactoryConstructor
protected final AtomicInteger invalidationListenerCount
InvalidationListener
from clients.protected Object wanMergePolicy
protected WanReplicationPublisher wanReplicationPublisher
protected volatile Evictor evictor
protected volatile MapConfig mapConfig
public MapContainer(String name, Config config, MapServiceContext mapServiceContext)
PostJoinAwareService.getPostJoinOperation()
Otherwise undesired situations, like deadlocks, may appear.public Indexes createIndexes(boolean global)
global
- set true
to create global indexes, otherwise set
false
to have partitioned indexespublic boolean isAddEventPublishingEnabled()
public void initEvictor()
public MapEvictionPolicy getMapEvictionPolicy()
protected boolean shouldUseGlobalIndex(MapConfig mapConfig)
protected static MemoryInfoAccessor getMemoryInfoAccessor()
public void initWanReplication(NodeEngine nodeEngine)
public Indexes getIndexes()
public Indexes getIndexes(int partitionId)
partitionId
- partitionIdpublic boolean isGlobalIndexEnabled()
public WanReplicationPublisher getWanReplicationPublisher()
public Object getWanMergePolicy()
public boolean isWanReplicationEnabled()
public boolean isWanRepublishingEnabled()
public void checkWanReplicationQueues()
WANReplicationQueueFullException
- if WAN replication is enabled and queue capacity has been reachedpublic int getTotalBackupCount()
public int getBackupCount()
public int getAsyncBackupCount()
public PartitioningStrategy getPartitioningStrategy()
public MapServiceContext getMapServiceContext()
public MapStoreContext getMapStoreContext()
public MapConfig getMapConfig()
public void setMapConfig(MapConfig mapConfig)
public EventJournalConfig getEventJournalConfig()
public String getName()
public String getQuorumName()
public ConstructorFunction<Void,RecordFactory> getRecordFactoryConstructor()
public QueryableEntry newQueryEntry(Data key, Object value)
public Evictor getEvictor()
public void setEvictor(Evictor evictor)
public Extractors getExtractors()
public boolean hasInvalidationListener()
public void increaseInvalidationListenerCount()
public void decreaseInvalidationListenerCount()
public InterceptorRegistry getInterceptorRegistry()
public void onDestroy()
public boolean shouldCloneOnEntryProcessing(int partitionId)
public ObjectNamespace getObjectNamespace()
public boolean isPersistWanReplicatedData()
Copyright © 2021 Hazelcast, Inc.. All Rights Reserved.