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

Methods

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)
Collection<Data>	flush()
Object	flush(Data key, Object value, long now, boolean backup)
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)
void	reset()

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

convertToObjectKeys, getStore, 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()

load

public Object load(Data key)

loadable

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

flush

public Collection<Data> flush()

flush

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

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