com.hazelcast.replicatedmap.impl.record

Class AbstractReplicatedRecordStore<K,V>

java.lang.Object

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

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 AbstractBaseReplicatedRecordStore<K,V>

This is the base class for all ReplicatedRecordStore implementations

Field Summary

Fields inherited from class com.hazelcast.replicatedmap.impl.record.AbstractBaseReplicatedRecordStore

eventService, isLoaded, name, nodeEngine, partitionId, partitionService, replicatedMapConfig, replicatedMapService, serializationService, storageRef, 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)
Set	entrySet(boolean lazy)
void	evict(Object key)
Object	get(Object key)
ReplicatedRecord	getReplicatedRecord(Object key)
boolean	isEmpty()
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	reset()
protected void	sendReplicationOperation(boolean isRemove, String name, Data key, Data value, long ttl, VersionResponsePair response)
int	size()
Collection	values(boolean lazy)
Collection	values(Comparator comparator)

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

cancelTtlEntry, destroy, equals, getName, getRecords, getStats, getStorage, getStorageRef, getVersion, hashCode, isLoaded, scheduleTtlEntry, setLoaded, setVersion

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

Constructor Detail

AbstractReplicatedRecordStore

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

Method Detail

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)