K
- key typeV
- value typepublic abstract class AbstractReplicatedRecordStore<K,V> extends Object
ReplicatedRecordStore
implementationsModifier and Type | Field and Description |
---|---|
protected EventService |
eventService |
protected AtomicBoolean |
isLoaded |
protected String |
name |
protected NodeEngineImpl |
nodeEngine |
protected int |
partitionId |
protected InternalPartitionService |
partitionService |
protected ReplicatedMapConfig |
replicatedMapConfig |
protected ReplicatedMapService |
replicatedMapService |
protected SerializationService |
serializationService |
protected AtomicReference<InternalReplicatedMapStorage<K,V>> |
storageRef |
protected EntryTaskScheduler |
ttlEvictionScheduler |
Constructor and Description |
---|
AbstractReplicatedRecordStore(String name,
ReplicatedMapService replicatedMapService,
int partitionId) |
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
marshall, unmarshall
protected final AtomicReference<InternalReplicatedMapStorage<K,V>> storageRef
protected final ReplicatedMapService replicatedMapService
protected final ReplicatedMapConfig replicatedMapConfig
protected final NodeEngineImpl nodeEngine
protected final SerializationService serializationService
protected final InternalPartitionService partitionService
protected final AtomicBoolean isLoaded
protected final EntryTaskScheduler ttlEvictionScheduler
protected final EventService eventService
protected final String name
protected int partitionId
public AbstractReplicatedRecordStore(String name, ReplicatedMapService replicatedMapService, int partitionId)
public void removeTombstone(Object key)
public void evict(Object key)
public boolean containsKey(Object key)
public boolean containsValue(Object value)
public Set keySet(boolean lazy)
public Collection values(boolean lazy)
public Collection values(Comparator comparator)
public Set entrySet(boolean lazy)
public ReplicatedRecord getReplicatedRecord(Object key)
public boolean isEmpty()
public int size()
public void clear()
public void reset()
public Iterator recordIterator()
public void putRecord(RecordMigrationInfo record)
public boolean merge(Object key, ReplicatedMapEntryView mergingEntry, ReplicatedMapMergePolicy policy)
protected void sendReplicationOperation(boolean isRemove, String name, Data key, Data value, long ttl, VersionResponsePair response)
public InternalReplicatedMapStorage<K,V> getStorage()
getStorage
in interface ReplicatedRecordStore
public AtomicReference<InternalReplicatedMapStorage<K,V>> getStorageRef()
public String getName()
getName
in interface ReplicatedRecordStore
public LocalReplicatedMapStatsImpl getStats()
public void destroy()
destroy
in interface ReplicatedRecordStore
public long getVersion()
getVersion
in interface ReplicatedRecordStore
public void setVersion(long version)
setVersion
in interface ReplicatedRecordStore
public Set<ReplicatedRecord> getRecords()
public boolean isLoaded()
isLoaded
in interface ReplicatedRecordStore
public void setLoaded(boolean loaded)
setLoaded
in interface ReplicatedRecordStore
Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.