com.hazelcast.replicatedmap.impl.record

Class AbstractReplicatedRecordStore<K,V>

java.lang.Object

com.hazelcast.replicatedmap.impl.record.AbstractReplicatedRecordStore<K,V>

Type Parameters:

K - key type

V - value type

All Implemented Interfaces:

ReplicatedRecordStore

Direct Known Subclasses:

DataReplicatedRecordStore, ObjectReplicatedRecordStorage

public abstract class AbstractReplicatedRecordStore<K,V>
extends Object

This is the base class for all ReplicatedRecordStore implementations

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
AbstractReplicatedRecordStore(String name, ReplicatedMapService replicatedMapService, int partitionId)

Method Summary

Methods

Modifier and Type	Method and Description
void	clear()
boolean	containsKey(Object key)
boolean	containsValue(Object value)
void	destroy()
Set	entrySet(boolean lazy)
boolean	equals(Object o)
void	evict(Object key)
Object	get(Object key)
String	getName()
Set<ReplicatedRecord>	getRecords()
ReplicatedRecord	getReplicatedRecord(Object key)
LocalReplicatedMapStatsImpl	getStats()
InternalReplicatedMapStorage<K,V>	getStorage()
AtomicReference<InternalReplicatedMapStorage<K,V>>	getStorageRef()
long	getVersion()
int	hashCode()
boolean	isEmpty()
boolean	isLoaded()
Set	keySet(boolean lazy)
boolean	merge(Object key, ReplicatedMapEntryView mergingEntry, ReplicatedMapMergePolicy policy)
Object	put(Object key, Object value)
Object	put(Object key, Object value, long ttl, TimeUnit timeUnit, boolean incrementHits)
void	putRecord(RecordMigrationInfo record)
Iterator	recordIterator()
Object	remove(Object key)
void	removeTombstone(Object key)
void	reset()
protected void	sendReplicationOperation(boolean isRemove, String name, Data key, Data value, long ttl, VersionResponsePair response)
void	setLoaded(boolean loaded)
void	setVersion(long version)
int	size()
Collection	values(boolean lazy)
Collection	values(Comparator comparator)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hazelcast.replicatedmap.impl.record.ReplicatedRecordStore

marshall, unmarshall

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

AbstractReplicatedRecordStore

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

Method Detail

removeTombstone

public void removeTombstone(Object key)

remove

public Object remove(Object key)

evict

public void evict(Object key)

get

public Object get(Object key)

put

public Object put(Object key,
         Object value)

put

public Object put(Object key,
         Object value,
         long ttl,
         TimeUnit timeUnit,
         boolean incrementHits)

containsKey

public boolean containsKey(Object key)

containsValue

public boolean containsValue(Object value)

keySet

public Set keySet(boolean lazy)

values

public Collection values(boolean lazy)

values

public Collection values(Comparator comparator)

entrySet

public Set entrySet(boolean lazy)

getReplicatedRecord

public ReplicatedRecord getReplicatedRecord(Object key)

isEmpty

public boolean isEmpty()

size

public int size()

clear

public void clear()

reset

public void reset()

recordIterator

public Iterator recordIterator()

putRecord

public void putRecord(RecordMigrationInfo record)

merge

public boolean merge(Object key,
            ReplicatedMapEntryView mergingEntry,
            ReplicatedMapMergePolicy policy)

sendReplicationOperation

protected void sendReplicationOperation(boolean isRemove,
                            String name,
                            Data key,
                            Data value,
                            long ttl,
                            VersionResponsePair response)

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