K
- key typeV
- value typepublic abstract class AbstractBaseReplicatedRecordStore<K,V> extends Object implements ReplicatedRecordStore
Modifier 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<Object,Object> |
ttlEvictionScheduler |
Modifier | Constructor and Description |
---|---|
protected |
AbstractBaseReplicatedRecordStore(String name,
ReplicatedMapService replicatedMapService,
int partitionId) |
Modifier and Type | Method and Description |
---|---|
ScheduledEntry<Object,Object> |
cancelTtlEntry(Object key) |
void |
destroy() |
boolean |
equals(Object o) |
String |
getName() |
Set<ReplicatedRecord> |
getRecords() |
LocalReplicatedMapStatsImpl |
getStats() |
InternalReplicatedMapStorage<K,V> |
getStorage() |
AtomicReference<InternalReplicatedMapStorage<K,V>> |
getStorageRef() |
long |
getVersion() |
int |
hashCode() |
boolean |
isLoaded() |
boolean |
scheduleTtlEntry(long delayMillis,
Object key,
Object value) |
void |
setLoaded(boolean loaded) |
void |
setVersion(long version) |
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
clear, containsKey, containsValue, entrySet, evict, get, getReplicatedRecord, isEmpty, keySet, marshall, merge, put, put, putRecord, recordIterator, remove, reset, size, unmarshall, values, values
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<Object,Object> ttlEvictionScheduler
protected final EventService eventService
protected final String name
protected int partitionId
protected AbstractBaseReplicatedRecordStore(String name, ReplicatedMapService replicatedMapService, int partitionId)
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 ScheduledEntry<Object,Object> cancelTtlEntry(Object key)
cancelTtlEntry
in interface ReplicatedRecordStore
public boolean scheduleTtlEntry(long delayMillis, Object key, Object value)
scheduleTtlEntry
in interface ReplicatedRecordStore
public boolean isLoaded()
isLoaded
in interface ReplicatedRecordStore
public void setLoaded(boolean loaded)
setLoaded
in interface ReplicatedRecordStore
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.