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

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

This is a InMemoryFormat.OBJECT based ReplicatedRecordStore implementation

Field Summary

Fields

Modifier and Type	Field and Description
protected EventService	eventService
protected AtomicBoolean	isLoaded
protected String	name
protected NodeEngineImpl	nodeEngine
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 Summary

Constructors

Constructor and Description
ObjectReplicatedRecordStorage(String name, ReplicatedMapService replicatedMapService, int partitionId)

Method Summary

Methods

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 key)
void	setLoaded(boolean loaded)
void	setVersion(long version)
Object	unmarshall(Object key)

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

clear, containsKey, containsValue, entrySet, evict, get, getReplicatedRecord, isEmpty, keySet, merge, put, put, putRecord, recordIterator, remove, removeTombstone, reset, sendReplicationOperation, size, values, values

Methods inherited from class java.lang.Object

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

Field Detail

storageRef

protected final AtomicReference<InternalReplicatedMapStorage<K,V>> storageRef

replicatedMapService

protected final ReplicatedMapService replicatedMapService

replicatedMapConfig

protected final ReplicatedMapConfig replicatedMapConfig

nodeEngine

protected final NodeEngineImpl nodeEngine

serializationService

protected final SerializationService serializationService

partitionService

protected final InternalPartitionService partitionService

isLoaded

protected final AtomicBoolean isLoaded

ttlEvictionScheduler

protected final EntryTaskScheduler ttlEvictionScheduler

eventService

protected final EventService eventService

name

protected final String name

partitionId

protected int partitionId

Constructor Detail

ObjectReplicatedRecordStorage

public ObjectReplicatedRecordStorage(String name,
                             ReplicatedMapService replicatedMapService,
                             int partitionId)

Method Detail

unmarshall

public Object unmarshall(Object key)

marshall

public Object marshall(Object key)

getStorage

public InternalReplicatedMapStorage<K,V> getStorage()

Specified by:

getStorage in interface ReplicatedRecordStore

getStorageRef

public AtomicReference<InternalReplicatedMapStorage<K,V>> getStorageRef()

getName

public String getName()

Specified by:

getName in interface ReplicatedRecordStore

getStats

public LocalReplicatedMapStatsImpl getStats()

destroy

public void destroy()

Specified by:

destroy in interface ReplicatedRecordStore

getVersion

public long getVersion()

Specified by:

getVersion in interface ReplicatedRecordStore

setVersion

public void setVersion(long version)

Specified by:

setVersion in interface ReplicatedRecordStore

getRecords

public Set<ReplicatedRecord> getRecords()

isLoaded

public boolean isLoaded()

Specified by:

isLoaded in interface ReplicatedRecordStore

setLoaded

public void setLoaded(boolean loaded)

Specified by:

setLoaded in interface ReplicatedRecordStore

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object