com.hazelcast.replicatedmap.impl.record
Class DataReplicatedRecordStore

java.lang.Object
  com.hazelcast.replicatedmap.impl.record.AbstractReplicatedRecordStore<Data,Data>
      com.hazelcast.replicatedmap.impl.record.DataReplicatedRecordStore

All Implemented Interfaces:

ReplicatedRecordStore, InitializingObject

public class DataReplicatedRecordStore
extends AbstractReplicatedRecordStore<Data,Data>

This is a Data based ReplicatedRecordStore implementation

Field Summary

protected Member	localMember
protected int	localMemberHash
protected LocalReplicatedMapStatsImpl	mapStats
protected ReplicatedMapConfig	replicatedMapConfig
protected ReplicatedMapService	replicatedMapService
protected ReplicationPublisher	replicationPublisher
protected com.hazelcast.replicatedmap.impl.record.InternalReplicatedMapStorage<K,V>	storage

Constructor Summary

DataReplicatedRecordStore(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

localMemberHash

protected final int localMemberHash

localMember

protected final Member localMember

Constructor Detail

DataReplicatedRecordStore

public DataReplicatedRecordStore(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