com.hazelcast.replicatedmap.impl.record

Interface ReplicatedRecordStore

All Known Implementing Classes:

AbstractBaseReplicatedRecordStore, AbstractReplicatedRecordStore, DataReplicatedRecordStore, ObjectReplicatedRecordStorage

public interface ReplicatedRecordStore

This interface describes a common record store for replicated maps and their actual records

Method Summary

Modifier and Type	Method and Description
ScheduledEntry<Object,Object>	cancelTtlEntry(Object key)
void	clear()
void	clearWithVersion(long version)
boolean	containsKey(Object key)
boolean	containsValue(Object value)
void	destroy()
Set	entrySet(boolean lazy)
void	evict(Object key)
Object	get(Object key)
String	getName()
int	getPartitionId()
ReplicatedRecord	getReplicatedRecord(Object key)
InternalReplicatedMapStorage	getStorage()
long	getVersion()
boolean	isEmpty()
boolean	isLoaded()
boolean	isStale(long version)
Set	keySet(boolean lazy)
Object	marshall(Object key)
boolean	merge(Object key, ReplicatedMapEntryView entryView, ReplicatedMapMergePolicy mergePolicy) Merges the given ReplicatedMapEntryView via the given ReplicatedMapMergePolicy.
boolean	merge(SplitBrainMergeTypes.ReplicatedMapMergeTypes mergingEntry, SplitBrainMergePolicy<Object,SplitBrainMergeTypes.ReplicatedMapMergeTypes> mergePolicy) Merges the given SplitBrainMergeTypes.ReplicatedMapMergeTypes via the given SplitBrainMergePolicy.
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<ReplicatedRecord>	recordIterator()
Object	remove(Object key)
Object	removeWithVersion(Object key, long version)
void	reset()
boolean	scheduleTtlEntry(long delayMillis, Object key, Object object)
void	setLoaded(boolean loaded)
int	size()
Object	unmarshall(Object key)
Collection	values(boolean lazy)
Collection	values(Comparator comparator)

Method Detail

getName

String getName()

getPartitionId

int getPartitionId()

remove

Object remove(Object key)

removeWithVersion

Object removeWithVersion(Object key,
                         long version)

evict

void evict(Object key)

get

Object get(Object key)

put

Object put(Object key,
           Object value)

put

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

putWithVersion

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

containsKey

boolean containsKey(Object key)

containsValue

boolean containsValue(Object value)

getReplicatedRecord

ReplicatedRecord getReplicatedRecord(Object key)

keySet

Set keySet(boolean lazy)

values

Collection values(boolean lazy)

values

Collection values(Comparator comparator)

entrySet

Set entrySet(boolean lazy)

size

int size()

clear

void clear()

clearWithVersion

void clearWithVersion(long version)

reset

void reset()

isEmpty

boolean isEmpty()

unmarshall

Object unmarshall(Object key)

marshall

Object marshall(Object key)

destroy

void destroy()

getVersion

long getVersion()

isStale

boolean isStale(long version)

recordIterator

Iterator<ReplicatedRecord> recordIterator()

putRecords

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

getStorage

InternalReplicatedMapStorage getStorage()

cancelTtlEntry

ScheduledEntry<Object,Object> cancelTtlEntry(Object key)

scheduleTtlEntry

boolean scheduleTtlEntry(long delayMillis,
                         Object key,
                         Object object)

isLoaded

boolean isLoaded()

setLoaded

void setLoaded(boolean loaded)

merge

boolean merge(SplitBrainMergeTypes.ReplicatedMapMergeTypes mergingEntry,
              SplitBrainMergePolicy<Object,SplitBrainMergeTypes.ReplicatedMapMergeTypes> mergePolicy)

Merges the given SplitBrainMergeTypes.ReplicatedMapMergeTypes via the given SplitBrainMergePolicy.

Parameters:

mergingEntry - the SplitBrainMergeTypes.ReplicatedMapMergeTypes instance to merge

mergePolicy - the SplitBrainMergePolicy instance to apply

Returns:

true if merge is applied, otherwise false

merge

boolean merge(Object key,
              ReplicatedMapEntryView entryView,
              ReplicatedMapMergePolicy mergePolicy)

Merges the given ReplicatedMapEntryView via the given ReplicatedMapMergePolicy.

Parameters:

entryView - the ReplicatedMapEntryView instance to merge

mergePolicy - the ReplicatedMapMergePolicy instance to apply

Returns:

true if merge is applied, otherwise false