com.hazelcast.replicatedmap.impl.record
Class ObjectReplicatedRecordStorage<K,V>

java.lang.Object
  com.hazelcast.replicatedmap.impl.record.AbstractReplicatedRecordStore<K,V>
      com.hazelcast.replicatedmap.impl.record.ObjectReplicatedRecordStorage<K,V>

Type Parameters:

K - key type

V - value type

All Implemented Interfaces:

ReplicatedRecordStore, InitializingObject

public class ObjectReplicatedRecordStorage<K,V>
extends AbstractReplicatedRecordStore<K,V>

This is a InMemoryFormat.OBJECT based ReplicatedRecordStore implementation

Field Summary

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 Summary

ObjectReplicatedRecordStorage(String name, NodeEngine nodeEngine, ReplicatedMapService replicatedMapService)

Method Summary

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)

Methods inherited from class com.hazelcast.replicatedmap.impl.record.AbstractReplicatedRecordStore

addEntryListener, addEntryListener, clear, containsKey, containsValue, entrySet, evict, get, getReplicatedRecord, isEmpty, keySet, put, put, remove, removeEntryListenerInternal, removeTombstone, size, values, values

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Field Detail

mapStats

protected final LocalReplicatedMapStatsImpl mapStats

storage

protected final com.hazelcast.replicatedmap.impl.record.InternalReplicatedMapStorage<K,V> storage

replicatedMapService

protected final ReplicatedMapService replicatedMapService

replicationPublisher

protected final ReplicationPublisher replicationPublisher

replicatedMapConfig

protected final ReplicatedMapConfig replicatedMapConfig

nodeEngine

protected final NodeEngine nodeEngine

localMemberHash

protected final int localMemberHash

localMember

protected final Member localMember

Constructor Detail

ObjectReplicatedRecordStorage

public ObjectReplicatedRecordStorage(String name,
                                     NodeEngine nodeEngine,
                                     ReplicatedMapService replicatedMapService)

Method Detail

unmarshallKey

public Object unmarshallKey(Object key)

unmarshallValue

public Object unmarshallValue(Object value)

marshallKey

public Object marshallKey(Object key)

marshallValue

public Object marshallValue(Object value)

getName

public String getName()

Specified by:

getName in interface ReplicatedRecordStore

initialize

public void initialize()

Specified by:

initialize in interface InitializingObject

destroy

public void destroy()

Specified by:

destroy in interface ReplicatedRecordStore

getReplicationPublisher

public ReplicationPublisher<K,V> getReplicationPublisher()

Specified by:

getReplicationPublisher in interface ReplicatedRecordStore

createReplicatedMapStats

public LocalReplicatedMapStats createReplicatedMapStats()

getReplicatedMapStats

public LocalReplicatedMapStatsImpl getReplicatedMapStats()

finalChunkReceived

public void finalChunkReceived()

isLoaded

public boolean isLoaded()

getLocalMemberHash

public int getLocalMemberHash()

getReplicatedMapService

public ReplicatedMapService getReplicatedMapService()

getRecords

public Set<ReplicatedRecord> getRecords()

getMutex

protected Object getMutex(Object key)

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object