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, SerializationService 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)
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

convertToObjectKeys, getStore, isPostProcessingMapStore, loadAll, removeAll, toData, 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,
                         SerializationService 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)

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