com.hazelcast.replicatedmap.impl.record
K
- key typeV
- value typepublic class ObjectReplicatedRecordStorage<K,V> extends AbstractReplicatedRecordStore<K,V>
InMemoryFormat.OBJECT
based
ReplicatedRecordStore
implementationModifier and Type | Field and Description |
---|---|
protected Member |
localMember |
protected int |
localMemberHash |
protected LocalReplicatedMapStatsImpl |
mapStats |
protected NodeEngine |
nodeEngine |
protected ReplicatedMapConfig |
replicatedMapConfig |
protected ReplicatedMapService |
replicatedMapService |
protected ReplicationPublisher |
replicationPublisher |
protected com.hazelcast.replicatedmap.impl.record.InternalReplicatedMapStorage<K,V> |
storage |
Constructor and Description |
---|
ObjectReplicatedRecordStorage(String name,
NodeEngine nodeEngine,
ReplicatedMapService replicatedMapService) |
Modifier and Type | Method and Description |
---|---|
LocalReplicatedMapStats |
createReplicatedMapStats() |
void |
destroy() |
boolean |
equals(Object o) |
void |
finalChunkReceived() |
int |
getLocalMemberHash() |
protected Object |
getMutex(Object key) |
String |
getName() |
Set<ReplicatedRecord> |
getRecords() |
ReplicatedMapService |
getReplicatedMapService() |
LocalReplicatedMapStatsImpl |
getReplicatedMapStats() |
ReplicationPublisher<K,V> |
getReplicationPublisher() |
int |
hashCode() |
void |
initialize() |
boolean |
isLoaded() |
Object |
marshallKey(Object key) |
Object |
marshallValue(Object value) |
Object |
unmarshallKey(Object key) |
Object |
unmarshallValue(Object value) |
addEntryListener, addEntryListener, clear, containsKey, containsValue, entrySet, evict, get, getReplicatedRecord, isEmpty, keySet, put, put, remove, removeEntryListenerInternal, removeTombstone, size, values, values
protected final LocalReplicatedMapStatsImpl mapStats
protected final com.hazelcast.replicatedmap.impl.record.InternalReplicatedMapStorage<K,V> storage
protected final ReplicatedMapService replicatedMapService
protected final ReplicationPublisher replicationPublisher
protected final ReplicatedMapConfig replicatedMapConfig
protected final NodeEngine nodeEngine
protected final int localMemberHash
protected final Member localMember
public ObjectReplicatedRecordStorage(String name, NodeEngine nodeEngine, ReplicatedMapService replicatedMapService)
public String getName()
getName
in interface ReplicatedRecordStore
public void initialize()
initialize
in interface InitializingObject
public void destroy()
destroy
in interface ReplicatedRecordStore
public ReplicationPublisher<K,V> getReplicationPublisher()
getReplicationPublisher
in interface ReplicatedRecordStore
public LocalReplicatedMapStats createReplicatedMapStats()
public LocalReplicatedMapStatsImpl getReplicatedMapStats()
public void finalChunkReceived()
public boolean isLoaded()
public int getLocalMemberHash()
public ReplicatedMapService getReplicatedMapService()
public Set<ReplicatedRecord> getRecords()
Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.