public class DataReplicatedRecordStore extends AbstractReplicatedRecordStore<Data,Data>
Data
based ReplicatedRecordStore
implementationModifier and Type | Field and Description |
---|---|
protected EventService |
eventService |
protected AtomicBoolean |
isLoaded |
protected String |
name |
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 |
---|
DataReplicatedRecordStore(String name,
ReplicatedMapService replicatedMapService,
int partitionId) |
Modifier and Type | Method and Description |
---|---|
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() |
Object |
marshall(Object object) |
void |
setLoaded(boolean loaded) |
void |
setVersion(long version) |
Object |
unmarshall(Object object) |
clear, containsKey, containsValue, entrySet, evict, get, getReplicatedRecord, isEmpty, keySet, merge, put, put, putRecord, recordIterator, remove, removeTombstone, reset, sendReplicationOperation, size, values, values
protected final AtomicReference<InternalReplicatedMapStorage<K,V>> storageRef
protected final ReplicatedMapService replicatedMapService
protected final ReplicatedMapConfig replicatedMapConfig
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 DataReplicatedRecordStore(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 boolean isLoaded()
isLoaded
in interface ReplicatedRecordStore
public void setLoaded(boolean loaded)
setLoaded
in interface ReplicatedRecordStore
Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.