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 NodeEngine |
nodeEngine |
protected int |
partitionId |
protected IPartitionService |
partitionService |
protected ReplicatedMapConfig |
replicatedMapConfig |
protected ReplicatedMapService |
replicatedMapService |
protected SerializationService |
serializationService |
protected AtomicReference<InternalReplicatedMapStorage<K,V>> |
storageRef |
Modifier | Constructor and Description |
---|---|
protected |
AbstractBaseReplicatedRecordStore(String name,
ReplicatedMapService replicatedMapService,
int partitionId) |
Modifier and Type | Method and Description |
---|---|
ScheduledEntry<Object,Object> |
cancelTtlEntry(Object key) |
protected InternalReplicatedMapStorage<K,V> |
clearInternal() |
void |
destroy() |
boolean |
equals(Object o) |
String |
getName() |
int |
getPartitionId() |
Set<ReplicatedRecord> |
getRecords() |
LocalReplicatedMapStatsImpl |
getStats() |
InternalReplicatedMapStorage<K,V> |
getStorage() |
AtomicReference<InternalReplicatedMapStorage<K,V>> |
getStorageRef() |
EntryTaskScheduler |
getTtlEvictionScheduler() |
long |
getVersion() |
int |
hashCode() |
boolean |
isLoaded() |
boolean |
isStale(long version) |
boolean |
scheduleTtlEntry(long delayMillis,
Object key,
Object value) |
void |
setLoaded(boolean loaded) |
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
clear, clearWithVersion, containsKey, containsValue, entrySet, evict, get, getReplicatedRecord, isEmpty, keySet, marshall, merge, merge, put, put, putRecords, putWithVersion, recordIterator, remove, removeWithVersion, reset, size, unmarshall, values, values
protected int partitionId
protected final String name
protected final NodeEngine nodeEngine
protected final EventService eventService
protected final IPartitionService partitionService
protected final ReplicatedMapConfig replicatedMapConfig
protected final SerializationService serializationService
protected final ReplicatedMapService replicatedMapService
protected final AtomicReference<InternalReplicatedMapStorage<K,V>> storageRef
protected final AtomicBoolean isLoaded
protected AbstractBaseReplicatedRecordStore(String name, ReplicatedMapService replicatedMapService, int partitionId)
public InternalReplicatedMapStorage<K,V> getStorage()
getStorage
in interface ReplicatedRecordStore
public AtomicReference<InternalReplicatedMapStorage<K,V>> getStorageRef()
public EntryTaskScheduler getTtlEvictionScheduler()
public int getPartitionId()
getPartitionId
in interface ReplicatedRecordStore
public String getName()
getName
in interface ReplicatedRecordStore
public LocalReplicatedMapStatsImpl getStats()
public void destroy()
destroy
in interface ReplicatedRecordStore
protected InternalReplicatedMapStorage<K,V> clearInternal()
public long getVersion()
getVersion
in interface ReplicatedRecordStore
public boolean isStale(long version)
isStale
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 © 2019 Hazelcast, Inc.. All Rights Reserved.