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

WriteThroughStore(MapStoreWrapper store, SerializationService serializationService)

Method Summary

Object	add(Data key, Object value, long time)
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, long now, boolean backup) Flushes the supplied key to the map-store.
Object	load(Data key)
boolean	loadable(Data key, long lastUpdateTime, long now)
int	notFinishedOperationsCount()
void	remove(Data key, long time)
void	removeBackup(Data key, long time)

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)

clear

public void clear()

Description copied from interface: MapDataStore

Clears resources of this map-data-store.

load

public Object load(Data key)

loadable

public boolean loadable(Data key,
                        long lastUpdateTime,
                        long now)

flush

public Collection<Data> flush()

Description copied from interface: MapDataStore

Flushes all keys in this map-store.

Returns:

flushed Data keys list.

flush

public Object flush(Data key,
                    Object value,
                    long now,
                    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

now - now in millis

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

Returns:

flushed value.

notFinishedOperationsCount

public int notFinishedOperationsCount()