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

Modifier and Type	Method and Description
void	clear()
void	clearWithVersion(long version)
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(MergingEntryHolder<Object,Object> mergingEntry, SplitBrainMergePolicy mergePolicy) Merges the given MergingEntryHolder via the given SplitBrainMergePolicy.
boolean	merge(Object key, ReplicatedMapEntryView mergingEntry, ReplicatedMapMergePolicy mergePolicy) Merges the given ReplicatedMapEntryView via the given ReplicatedMapMergePolicy.
Object	put(Object key, Object value)
Object	put(Object key, Object value, long ttl, TimeUnit timeUnit, boolean incrementHits)
void	putRecords(Collection<RecordMigrationInfo> records, long version)
Object	putWithVersion(Object key, Object value, long ttl, TimeUnit timeUnit, boolean incrementHits, long version)
Iterator	recordIterator()
Object	remove(Object key)
Object	removeWithVersion(Object key, long version)
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, isStale, scheduleTtlEntry, setLoaded

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)

removeWithVersion

public Object removeWithVersion(Object key,
                                long version)

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)

putWithVersion

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

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()

clearWithVersion

public void clearWithVersion(long version)

reset

public void reset()

recordIterator

public Iterator recordIterator()

putRecords

public void putRecords(Collection<RecordMigrationInfo> records,
                       long version)

merge

public boolean merge(MergingEntryHolder<Object,Object> mergingEntry,
                     SplitBrainMergePolicy mergePolicy)

Description copied from interface: ReplicatedRecordStore

Merges the given MergingEntryHolder via the given SplitBrainMergePolicy.

Parameters:

mergingEntry - the MergingEntryHolder instance to merge

mergePolicy - the SplitBrainMergePolicy instance to apply

Returns:

true if merge is applied, otherwise false

merge

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

Description copied from interface: ReplicatedRecordStore

Merges the given ReplicatedMapEntryView via the given ReplicatedMapMergePolicy.

mergingEntry - the ReplicatedMapEntryView instance to merge

mergePolicy - the ReplicatedMapMergePolicy instance to apply

Returns:

true if merge is applied, otherwise false

sendReplicationOperation

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