com.hazelcast.map.impl.mapstore.writebehind

Class WriteBehindStore

java.lang.Object

com.hazelcast.map.impl.mapstore.AbstractMapDataStore<Data,Object>

com.hazelcast.map.impl.mapstore.writebehind.WriteBehindStore

All Implemented Interfaces:

MapDataStore<Data,Object>

public class WriteBehindStore
extends AbstractMapDataStore<Data,Object>

Write behind map data store implementation. Created per every record-store. Only called from one thread.

Constructor Summary

Constructors

Constructor and Description
WriteBehindStore(MapStoreWrapper store, SerializationService serializationService, long writeDelayTime, int partitionId, InMemoryFormat inMemoryFormat, boolean coalesce)

Method Summary

Methods

Modifier and Type	Method and Description
Object	add(Data key, Object value, long now)
void	add(DelayedEntry<Data,Object> delayedEntry)
Object	addBackup(Data key, Object value, long time)
void	addTransient(Data key, long now)
void	clear() Clears resources of this map-data-store.
Collection<Data>	flush() Flushes all keys in this map-store.
Object	flush(Data key, Object value, boolean backup) Flushes the supplied key to the map-store.
AtomicInteger	getFlushCounter()
WriteBehindQueue<DelayedEntry>	getWriteBehindQueue()
Object	load(Data key)
boolean	loadable(Data key) * Used in IMap.loadAll(boolean) calls.
Map	loadAll(Collection keys)
int	notFinishedOperationsCount()
void	remove(Data key, long now)
void	removeBackup(Data key, long time)
void	setWriteBehindProcessor(WriteBehindProcessor writeBehindProcessor)
void	setWriteBehindQueue(WriteBehindQueue<DelayedEntry> writeBehindQueue)

Methods inherited from class com.hazelcast.map.impl.mapstore.AbstractMapDataStore

convertToObjectKeys, getStore, isPostProcessingMapStore, removeAll, toData, toObject

Methods inherited from class java.lang.Object

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

Constructor Detail

WriteBehindStore

public WriteBehindStore(MapStoreWrapper store,
                SerializationService serializationService,
                long writeDelayTime,
                int partitionId,
                InMemoryFormat inMemoryFormat,
                boolean coalesce)

Method Detail

add

public Object add(Data key,
         Object value,
         long now)

add

public void add(DelayedEntry<Data,Object> delayedEntry)

addTransient

public void addTransient(Data key,
                long now)

addBackup

public Object addBackup(Data key,
               Object value,
               long time)

remove

public void remove(Data key,
          long now)

removeBackup

public void removeBackup(Data key,
                long time)

clear

public void clear()

Description copied from interface: MapDataStore

Clears resources of this map-data-store.

load

public Object load(Data key)

loadAll

public Map loadAll(Collection keys)

Specified by:

loadAll in interface MapDataStore<Data,Object>

Overrides:

loadAll in class AbstractMapDataStore<Data,Object>

loadable

public boolean loadable(Data key)

* Used in IMap.loadAll(boolean) calls. If the write-behind map-store feature is enabled, some things may lead to possible data inconsistencies. These are: - calling evict/evictAll, - calling remove, and - not yet stored write-behind queue operations.

With this method, we can be sure if a key can be loadable from map-store or not.

Parameters:

key - the key to query whether it is loadable or not.

Returns:

true if loadable, false otherwise.

notFinishedOperationsCount

public int notFinishedOperationsCount()

flush

public Object flush(Data key,
           Object value,
           boolean backup)

Description copied from interface: MapDataStore

Flushes the supplied key to the map-store.

Parameters:

key - key to be flushed

value - value to be flushed

backup - true calling this method for backup partition, false for owner partition.

Returns:

flushed value.

flush

public Collection<Data> flush()

Description copied from interface: MapDataStore

Flushes all keys in this map-store.

Returns:

flushed Data keys list.

getWriteBehindQueue

public WriteBehindQueue<DelayedEntry> getWriteBehindQueue()

setWriteBehindQueue

public void setWriteBehindQueue(WriteBehindQueue<DelayedEntry> writeBehindQueue)

setWriteBehindProcessor

public void setWriteBehindProcessor(WriteBehindProcessor writeBehindProcessor)

getFlushCounter

public AtomicInteger getFlushCounter()