com.hazelcast.replicatedmap.impl.record
Class DataReplicatedRecordStore

java.lang.Object
  extended by com.hazelcast.replicatedmap.impl.record.AbstractReplicatedRecordStore<Data,Data>
      extended by 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


Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.