com.hazelcast.replicatedmap.impl.record

Class AbstractBaseReplicatedRecordStore<K,V>

java.lang.Object

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

Type Parameters:

K - key type

V - value type

All Implemented Interfaces:

ReplicatedRecordStore

Direct Known Subclasses:

AbstractReplicatedRecordStore

public abstract class AbstractBaseReplicatedRecordStore<K,V>
extends Object
implements ReplicatedRecordStore

Internal base class to encapsulate the internals from the interface methods of ReplicatedRecordStore

Field Summary

Fields

Modifier and Type	Field and Description
protected EventService	eventService
protected AtomicBoolean	isLoaded
protected String	name
protected NodeEngine	nodeEngine
protected int	partitionId
protected IPartitionService	partitionService
protected ReplicatedMapConfig	replicatedMapConfig
protected ReplicatedMapService	replicatedMapService
protected SerializationService	serializationService
protected AtomicReference<InternalReplicatedMapStorage<K,V>>	storageRef

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractBaseReplicatedRecordStore(String name, ReplicatedMapService replicatedMapService, int partitionId)

Method Summary

Modifier and Type	Method and Description
ScheduledEntry<Object,Object>	cancelTtlEntry(Object key)
protected InternalReplicatedMapStorage<K,V>	clearInternal()
void	destroy()
boolean	equals(Object o)
String	getName()
int	getPartitionId()
Set<ReplicatedRecord>	getRecords()
LocalReplicatedMapStatsImpl	getStats()
InternalReplicatedMapStorage<K,V>	getStorage()
AtomicReference<InternalReplicatedMapStorage<K,V>>	getStorageRef()
EntryTaskScheduler	getTtlEvictionScheduler()
long	getVersion()
int	hashCode()
boolean	isLoaded()
boolean	isStale(long version)
boolean	scheduleTtlEntry(long delayMillis, Object key, Object value)
void	setLoaded(boolean loaded)

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

clear, clearWithVersion, containsKey, containsValue, entrySet, evict, get, getReplicatedRecord, isEmpty, keySet, marshall, merge, merge, put, put, putRecords, putWithVersion, recordIterator, remove, removeWithVersion, reset, size, unmarshall, values, values

Field Detail

partitionId

protected int partitionId

name

protected final String name

nodeEngine

protected final NodeEngine nodeEngine

eventService

protected final EventService eventService

partitionService

protected final IPartitionService partitionService

replicatedMapConfig

protected final ReplicatedMapConfig replicatedMapConfig

serializationService

protected final SerializationService serializationService

replicatedMapService

protected final ReplicatedMapService replicatedMapService

storageRef

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

isLoaded

protected final AtomicBoolean isLoaded

Constructor Detail

AbstractBaseReplicatedRecordStore

protected AbstractBaseReplicatedRecordStore(String name,
                                            ReplicatedMapService replicatedMapService,
                                            int partitionId)

Method Detail

getStorage

public InternalReplicatedMapStorage<K,V> getStorage()

Specified by:

getStorage in interface ReplicatedRecordStore

getStorageRef

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

getTtlEvictionScheduler

public EntryTaskScheduler getTtlEvictionScheduler()

getPartitionId

public int getPartitionId()

Specified by:

getPartitionId in interface ReplicatedRecordStore

getName

public String getName()

Specified by:

getName in interface ReplicatedRecordStore

getStats

public LocalReplicatedMapStatsImpl getStats()

destroy

public void destroy()

Specified by:

destroy in interface ReplicatedRecordStore

clearInternal

protected InternalReplicatedMapStorage<K,V> clearInternal()

getVersion

public long getVersion()

Specified by:

getVersion in interface ReplicatedRecordStore

isStale

public boolean isStale(long version)

Specified by:

isStale in interface ReplicatedRecordStore

getRecords

public Set<ReplicatedRecord> getRecords()

cancelTtlEntry

public ScheduledEntry<Object,Object> cancelTtlEntry(Object key)

Specified by:

cancelTtlEntry in interface ReplicatedRecordStore

scheduleTtlEntry

public boolean scheduleTtlEntry(long delayMillis,
                                Object key,
                                Object value)

Specified by:

scheduleTtlEntry in interface ReplicatedRecordStore

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