com.hazelcast.map.impl.mapstore.writethrough

Class WriteThroughStore

java.lang.Object

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

com.hazelcast.map.impl.mapstore.writethrough.WriteThroughStore

All Implemented Interfaces:

MapDataStore<Data,Object>

public class WriteThroughStore
extends AbstractMapDataStore<Data,Object>

Write through map data store implementation. Created per map.

Constructor Summary

Constructors

Constructor and Description
WriteThroughStore(MapStoreWrapper store, InternalSerializationService serializationService)

Method Summary

Modifier and Type	Method and Description
Object	add(Data key, Object value, long time)
Object	addBackup(Data key, Object value, long time)
void	addTransient(Data key, long now)
Object	flush(Data key, Object value, boolean backup) Flushes the supplied key to the map-store.
void	hardFlush() Flushes write-behind-queue into map-store in calling thread.
Object	load(Data key)
boolean	loadable(Data key) Used in IMap.loadAll(boolean) calls.
int	notFinishedOperationsCount()
void	remove(Data key, long time)
void	removeBackup(Data key, long time)
void	reset() Returns all associated resources of this map-data-store back to the initial state.
long	softFlush() Only marks this MapDataStore as flush-able.

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

getStore, isPostProcessingMapStore, loadAll, removeAll, toHeapData, toObject

Methods inherited from class java.lang.Object

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

Constructor Detail

WriteThroughStore

public WriteThroughStore(MapStoreWrapper store,
                         InternalSerializationService serializationService)

Method Detail

add

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

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

removeBackup

public void removeBackup(Data key,
                         long time)

reset

public void reset()

Description copied from interface: MapDataStore

Returns all associated resources of this map-data-store back to the initial state.

load

public Object load(Data key)

loadable

public boolean loadable(Data key)

Description copied from interface: MapDataStore

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 the key is loadable

softFlush

public long softFlush()

Description copied from interface: MapDataStore

Only marks this MapDataStore as flush-able. Flush means storing entries from write-behind-queue into map-store regardless of the scheduled store-time. Actual flushing is done by another thread than partition-operation thread which runs StoreWorker.

Returns:

last given sequence number to the last store operation

See Also:

MapFlushOperation

hardFlush

public void hardFlush()

Description copied from interface: MapDataStore

Flushes write-behind-queue into map-store in calling thread.

After calling of this method, all elements in the WriteBehindQueue of this MapDataStore should be in map-store regardless of the scheduled store-time.

The only call to this method is in node-shutdown.

See Also:

MapManagedService.shutdown(boolean)

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.

notFinishedOperationsCount

public int notFinishedOperationsCount()